cassandra - SSTableSimpleUnsortedWriter 和列族比较器

Question

我正在尝试将 sstableloader 用于使用 cql 创建的 CF，如下所示：

CREATE TABLE test (
    a text,
    b text,
    c text,
    d int,
    e set<text>,
    f text,
    PRIMARY KEY ((a, b) c, d))

我应该如何在 SSTableSimpleUnsortedWriter 中定义列族比较器？或者更具体地说，当一列被定义为一个集合时它是如何工作的？

SSTableSimpleUnsortedWriter(File directory,
                                   IPartitioner partitioner,
                                   String keyspace,
                                   String columnFamily,
                                   AbstractType<?> comparator,
                                   AbstractType<?> subComparator,
                                   int bufferSizeInMB,
                                   CompressionParameters compressParameters)

Answer 1

您基本上必须查看存储引擎如何在内部存储该行 - 插入一些示例数据，然后从 cli 中列出它，应该会有所帮助，以及阅读http://www.datastax.com/dev/blog /thrift-to-cql3。

“正确”的解决方案是创建一个 CQL-aware Writer。