cassandra写，多线程

我有一些问题与cassandra 2.1.8 ，我使用的是cassandra-driver-core-2.1.6.jar 我使用10个线程插入cassandra约50000行（每个线程）在同一时间。但是，一些线程非常慢。一些线程时间与其他线程时间非常不同（时间，它需要插入50000行）。我认为需要调整cassandra。cassandra写，多线程

这是我的代码的一部分。

for(int i = 0; i < 50000; i++) { 
     bind = statement.bind("KEY" + i + thread + j, param); 
     resultSetFuture = session.executeAsync(bind); 
     if(i % 1000 == 0) { 
      futures.add(resultSetFuture); 
      for(ResultSetFuture future : futures) { 
       future.getUninterruptibly(); 
      } 
     } 
    }

你能帮助我吗？请.... 我是否需要更改任何设置？

来源

2015-07-21 KIM HR

1）你有多少个cassandra节点？

2）当你运行thate代码时他们在做什么？

3）你的模式是什么？

4）你认为你应该能够做到每秒多少次请求？

5）你对＃4的答案是基于什么？

来源

2015-07-29 03:27:29

cassandra写，多线程

回答

相关问题