2
私はcassandraを使用しています。タイムスタンプの指定された範囲の間にあるレコードを取得したいと思います。これに対する質問は何でしょうか？私は倹約クライアントを使用しています。cassandraからタイムスタンプの指定された範囲でレコードを取得する
私はこのコードを試しました。
String columnFamily = "UserColumnFamily";
String keyspace="Enterprise";
final String UTF8 = "UTF8";
String keyUserid="1";
TTransport tr = new TSocket("10.10.10.104", 9160);
TProtocol proto = new TBinaryProtocol(tr);
Cassandra.Client client = new Cassandra.Client(proto);
SlicePredicate predicate = new SlicePredicate();
SliceRange sliceRange = new SliceRange();
String startkey="1293443184521000";
String finishkey ="1293445102333000";
sliceRange.setStart(new byte[0]);
sliceRange.setFinish(new byte[0]);
predicate.setSlice_range(sliceRange);
ColumnParent parent = new ColumnParent(columnFamily);
try {
tr.open();
List<KeySlice> results=client.get_range_slice(keyspace,parent,predicate,startkey,finishkey,100, ConsistencyLevel.ONE);
for (KeySlice result : results) {
Column column = (Column) result.columns;
System.out.println(new String(column.name,UTF8) + " ->> "
+ new String(column.value,UTF8));
}
tr.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
しかし、それは、このエラーがスローされます。
InvalidRequestException(why:start key's md5 sorts after end key's md5.
This is not allowed; you probably should not specify end key at all, under RandomPartitioner
を私はnullにfinishkeyを置けば、それは言う：
Required field 'finish_key' was not present!
Struct: get_range_slice_args(keyspace:NiidleEnterprise,
column_parent:ColumnParent(column_family:UserColumnFamily),
predicate:SlicePredicate(slice_range:SliceRange(start:, finish:, reversed:false, count:100)),
start_key:1293443184521000, finish_key:null, row_count:100, consistency_level:ONE)"
私はstartkeyとして設定する値を理解していませんおよびfinishkey。 上記のコード内：
String startkey="1293443184521000";
String finishkey ="1293445102333000";
これらはタイムスタンプ値です。開始キーと終了キーのために何をすべきか教えてください。
あなたはどのクライアントを使用していますか？その情報はこれをはるかに有用な質問にするでしょう。 –