Replace deprecated compression options in cql

JanusGraph · Oct 8, 2024 · 3694c4a · 3694c4a
1 parent 73232fe
commit 3694c4a
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/docs/configs/janusgraph-cfg.md b/docs/configs/janusgraph-cfg.md
@@ -437,7 +437,7 @@ CQL storage backend options
 | storage.cql.compaction-strategy-options | Compaction strategy options.  This list is interpreted as a map.  It must have an even number of elements in [key,val,key,val,...] form. | String[] | (no default value) | FIXED |
 | storage.cql.compression | Whether the storage backend should use compression when storing the data | Boolean | true | FIXED |
 | storage.cql.compression-block-size | The size of the compression blocks in kilobytes | Integer | 64 | FIXED |
-| storage.cql.compression-type | The sstable_compression value JanusGraph uses when creating column families. This accepts any value allowed by Cassandra's sstable_compression option. Leave this unset to disable sstable_compression on JanusGraph-created CFs. | String | LZ4Compressor | MASKABLE |
+| storage.cql.compression-type | The compression class value JanusGraph uses when creating column families. This accepts any value allowed by Cassandra's compression class option. Leave this unset to disable compression class on JanusGraph-created CFs. | String | LZ4Compressor | MASKABLE |
 | storage.cql.gc-grace-seconds | The number of seconds before tombstones (deletion markers) are eligible for garbage-collection. | Integer | (no default value) | FIXED |
 | storage.cql.heartbeat-interval | The connection heartbeat interval in milliseconds. | Long | (no default value) | MASKABLE |
 | storage.cql.heartbeat-timeout | How long the driver waits for the response (in milliseconds) to a heartbeat. | Long | (no default value) | MASKABLE |

diff --git a/janusgraph-cql/src/main/java/org/janusgraph/diskstorage/cql/CQLConfigOptions.java b/janusgraph-cql/src/main/java/org/janusgraph/diskstorage/cql/CQLConfigOptions.java
@@ -178,9 +178,9 @@ public interface CQLConfigOptions {
     ConfigOption<String> CF_COMPRESSION_TYPE = new ConfigOption<>(
             CQL_NS,
             "compression-type",
-            "The sstable_compression value JanusGraph uses when creating column families. " +
-                    "This accepts any value allowed by Cassandra's sstable_compression option. " +
-                    "Leave this unset to disable sstable_compression on JanusGraph-created CFs.",
+            "The compression class value JanusGraph uses when creating column families. " +
+                    "This accepts any value allowed by Cassandra's compression class option. " +
+                    "Leave this unset to disable compression on JanusGraph-created CFs.",
             ConfigOption.Type.MASKABLE,
             "LZ4Compressor");
 

diff --git a/janusgraph-cql/src/main/java/org/janusgraph/diskstorage/cql/CQLKeyColumnValueStore.java b/janusgraph-cql/src/main/java/org/janusgraph/diskstorage/cql/CQLKeyColumnValueStore.java
@@ -331,7 +331,7 @@ private static CreateTableWithOptions compressionOptions(final CreateTableWithOp
         int chunkLengthInKb = configuration.get(CF_COMPRESSION_BLOCK_SIZE);
 
         return createTable.withOption("compression",
-            ImmutableMap.of("sstable_compression", compressionType, "chunk_length_kb", chunkLengthInKb));
+            ImmutableMap.of("class", compressionType, "chunk_length_in_kb", chunkLengthInKb));
     }
 
     static CreateTableWithOptions compactionOptions(final CreateTableWithOptions createTable,