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寫，多線程

回答

相關問題