Ошибка с использованием схемы DataStax для создания таблицы Cassandra в Java ⇐ JAVA

[Anonymous]

Я пытаюсь создать таблицу Cassandra из кода Java, используя класс схемы DataStax. По сути, я пытаюсь преобразовать этот запрос CQL: < /p>

Код: Выделить всё

CREATE TABLE  (id text, key blob, val blob, PRIMARY KEY (id, key))
WITH compaction={'class': 'LeveledCompactionStrategy'}
AND compression = {'sstable_compression' : 'LZ4Compressor' };
< /code>
в код Java, который выглядит так: < /p>
Create.Options createTable = SchemaBuilder.createTable(keyspace+"."+tableName)
.addPartitionKey("id", DataType.text())
.addClusteringColumn("key", DataType.blob())
.addColumn("val", DataType.blob())
.withOptions().compactionOptions(SchemaBuilder.leveledStrategy())
.compressionOptions(SchemaBuilder.lz4());

Проблема заключается в том, что это дает ошибку с опцией сжатия com.datastax.driver.core.exceptions.invalidconfigurationinqueryexception: отсутствующий суб-опция 'class' Для опции «сжатие». Смотрите эту проблему, поднятую где угодно, чтобы найти то, чего здесь не хватает. Я хотел бы знать, в чем проблема с запросом на Java и что было бы лучшим способом исправить его.

Подробнее здесь: https://stackoverflow.com/questions/796 ... le-in-java