This is an automated email from the ASF dual-hosted git repository.
samt pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/trunk by this push:
new e191aff Passing checksum and compressor as options from SimpleClient
e191aff is described below
commit e191aff385053bdb5325f15bc6d16d2dc0ee0589
Author: sumanthpasupuleti <sumanth.pasupuleti...@gmail.com>
AuthorDate: Sat Mar 16 23:35:32 2019 -0700
Passing checksum and compressor as options from SimpleClient
Patch by Sumanth Pasupuleti; reviewed by Sam Tunnicliffe for CASSANDRA-15056
---
CHANGES.txt | 1 +
src/java/org/apache/cassandra/transport/SimpleClient.java | 3 +++
2 files changed, 4 insertions(+)
diff --git a/CHANGES.txt b/CHANGES.txt
index b511c18..c6aaf2b 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
4.0
+ * SimpleClient should pass connection properties as options (CASSANDRA-15056)
* Set repaired data tracking flag on range reads if enabled (CASSANDRA-15019)
* Calculate pending ranges for BOOTSTRAP_REPLACE correctly (CASSANDRA-14802)
* Make TableCQLHelper reuse the single quote pattern (CASSANDRA-15033)
diff --git a/src/java/org/apache/cassandra/transport/SimpleClient.java
b/src/java/org/apache/cassandra/transport/SimpleClient.java
index 9ed4272..deba207 100644
--- a/src/java/org/apache/cassandra/transport/SimpleClient.java
+++ b/src/java/org/apache/cassandra/transport/SimpleClient.java
@@ -133,10 +133,13 @@ public class SimpleClient implements Closeable
{
Compressor compressor = useCompression ? LZ4Compressor.INSTANCE :
null;
connection.setTransformer(ChecksummingTransformer.getTransformer(ChecksumType.CRC32,
compressor));
+ options.put(StartupMessage.CHECKSUM, "crc32");
+ options.put(StartupMessage.COMPRESSION, "lz4");
}
else if (useCompression)
{
connection.setTransformer(CompressingTransformer.getTransformer(LZ4Compressor.INSTANCE));
+ options.put(StartupMessage.COMPRESSION, "lz4");
}
execute(new StartupMessage(options));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
