Skip to content

Commit 43fb05b

Browse files
committed
Change write consistency level: ConsistencyLevel.ANY ->
ConsistencyLevel.ONE
1 parent d351dc3 commit 43fb05b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

mrj-0.1/src/cn/edu/neu/mitt/mrj/io/dbs/CassandraDB.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -400,7 +400,7 @@ public void increaseRuleCounter(int field)
400400
List<ByteBuffer> args = new ArrayList<ByteBuffer>();
401401
args.add(ByteBufferUtil.bytes(field));
402402
CqlPreparedResult p_result = client.prepare_cql3_query(ByteBufferUtil.bytes(query), Compression.NONE);
403-
CqlResult result = client.execute_prepared_cql3_query(p_result.itemId, args, ConsistencyLevel.ANY);
403+
CqlResult result = client.execute_prepared_cql3_query(p_result.itemId, args, ConsistencyLevel.ONE);
404404
logger.info("Increase RuleCounter of " + field + ": " + result.getNum());
405405
}
406406

@@ -413,7 +413,7 @@ public void increaseTripletypeCounter(int field)
413413
List<ByteBuffer> args = new ArrayList<ByteBuffer>();
414414
args.add(ByteBufferUtil.bytes(field));
415415
CqlPreparedResult p_result = client.prepare_cql3_query(ByteBufferUtil.bytes(query), Compression.NONE);
416-
CqlResult result = client.execute_prepared_cql3_query(p_result.itemId, args, ConsistencyLevel.ANY);
416+
CqlResult result = client.execute_prepared_cql3_query(p_result.itemId, args, ConsistencyLevel.ONE);
417417
logger.info("Increase TripletypeCounter of " + field + ": " + result.getNum());
418418
}
419419

0 commit comments

Comments
 (0)