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 应该会有帮助。 .

“正确”的解决方案是 create a CQL-aware Writer .