adutra

package com.datastax.test;

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.MoreExecutors;

adutra

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.config.DefaultDriverOption;
import com.datastax.oss.driver.api.core.config.DriverExecutionProfile;
import com.datastax.oss.driver.api.core.cql.BatchStatement;
import com.datastax.oss.driver.api.core.cql.BatchStatementBuilder;
import com.datastax.oss.driver.api.core.cql.DefaultBatchType;
import com.datastax.oss.driver.api.core.cql.PreparedStatement;
import com.datastax.oss.driver.api.core.cql.ResultSet;
import com.datastax.oss.driver.api.core.cql.SimpleStatement;
import com.datastax.oss.driver.shaded.guava.common.base.Strings;

adutra

public static class SpliteratorBenchmark {
  static double sink;

  public static void main(String[] args) throws IOException {
    final Path inputPath = createInput();
    for (int i = 0; i < 3; i++) {
      System.out.println("Start processing JDK stream");
      measureProcessing(Files.lines(inputPath));
      System.out.println("Start processing fixed-batch stream");
      measureProcessing(withBatchSize(Files.lines(inputPath), 500));

adutra

Keybase proof

I hereby claim:

• I am adutra on github.
• I am alexdut (https://keybase.io/alexdut) on keybase.
• I have a public key ASBFlSfWiOiYkSGDel1lvqrMg9vu4ooklta73Ss64pAKcgo

To claim this, I am signing this object: