Astyanax:如何确定用于反序列化的动态列的类型

Question

我有一个包含字符串的列族和一个用于列名的复合类型。

当我将行作为ByteBuffers的ColumnList返回时，我需要知道该列的类型，以便使用适当的序列化程序。有没有办法获取类型，或者我应该用另一种方法？

代码：

ColumnFamily<String, ByteBuffer> cfBytes =  ColumnFamily.newColumnFamily("mycolumnfamily",StringSerializer.get(), ByteBufferSerializer.get());

ColumnFamilyQuery<String, ByteBuffer> cfq = keyspace.prepareQuery(cfBytes);

RowQuery<String, ByteBuffer> rowQuery = cfq.getKey("foobar");

ColumnList<ByteBuffer> result = rowQuery.execute().getResult();

Answer 1

对于常规复合列，可以仅使用复合类型或MockComposite类型，例如：

ColumnFamily<String, MockCompositeType> CF_COMPOSITE = 
    ColumnFamily.newColumnFamily("CompositeColumn", StringSerializer.get(),
        new AnnotatedCompositeSerializer<MockCompositeType>(MockCompositeType.class));

你可以找到更多的。

或者，编写纯Astyanax的另一种选择是。

Answer 2

如果您得到的是单行，则可以判断复合列的类型：

// Query the composite columns
@SuppressWarnings("rawtypes")
OperationResult<ColumnList<ColumnFamily>> result = null;
try {
    result = oKeyspace.getKeyspaceContext().
             getEntity().prepareQuery(compTestCF).getRow("12345").execute();
} catch (ConnectionException e1) {
    e1.printStackTrace();
}
for (@SuppressWarnings("rawtypes")
Column<ColumnFamily> col : result.getResult()) {
    String colClass = ((Object) col.getName()).getClass().getName();
    if (colClass.equals(CompositeColumn.class.getName())) {
    System.out.println(col.getLongValue());
    }
}       

我的复合列测试类的名称是CompositeColumn，如上所示。这样做的原因是因为OperationResult是一个ColumnList<ColumnFamily>对象。每个Column<ColumnFamily>对象都包含复合列对象作为名称，这使我们能够找到CompositeColumn类名。之所以可以这样做，是因为"getRow“或"getKey”调用的结果是一个RowQuery对象。

不幸的是，当返回多个行时，我还没有找到这样做的方法。在这种情况下，不会为每一行生成ColumnList<ColumnFamily>对象，而是生成ColumnList<Object>对象。这是因为任何切片或范围查询的结果都是一个RowSliceQuery对象，由于某种疯狂的原因，它不会给您提供相同的功能。col.getName()调用为复合列返回一个空字符串。