Tôi đang sử dụng mã này cho lấy user_id & user_codecột ngẫu nhiên lấy trong cassandra
Keyspace keyspace = HFactory.createKeyspace("test", cluster);
CqlQuery<String,String,ByteBuffer> cqlQuery = new CqlQuery<String,String,ByteBuffer>(keyspace, stringSerializer, stringSerializer, new ByteBufferSerializer());
cqlQuery.setQuery("select user_id,user_code from User");
QueryResult<CqlRows<String,String,ByteBuffer>> result = cqlQuery.execute();
Iterator iterator = result.get().iterator();
while(iterator.hasNext()) {
Row<String, String, ByteBuffer> row = (Row<String, String, ByteBuffer>) iterator.next();
System.out.println("\nInserted data is as follows:\n" + row.getColumnSlice().getColumns().get(0).getValue().getInt());
System.out.println("\nInserted data is as follows:\n" + Charset.forName("UTF-8").decode(row.getColumnSlice().getColumns().get(1).getValueBytes()));
}
Bây giờ vấn đề nằm ở đây mà tôi đang chuyển đổi các lĩnh vực theo loại hình cụ thể của họ
gì nếu truy vấn đi ngẫu nhiên? Làm thế nào để xử lý kịch bản đó?
Plz cố gắng sử dụng BufferSerialezer khác thay vì ByteBufferSerializer, thông qua u này sẽ luôn lấy tất cả dữ liệu trong luồng byte, cố gắng trích xuất dữ liệu từ cơ sở dữ liệu ở định dạng thực tế mà nó được lưu trữ. –