[BEAM-10017] Expose SocketOptions timeouts in CassandraIO

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 2.23.0
• Component/s: io-java-cassandra
• Assignee: Unassigned
• Reporter: Nathan Fisher
• Created: 16/May/20 16:53
• Updated: 15/Apr/21 08:26
• Resolved: 15/Apr/21 08:26

Description

Currently there are no options to tune the configuration of the CassandraIO reader/writer. This can be useful for either slow clusters, large queries, or high latency links.

The intent would be to expose the following configuration elements as setters on the CassandraIO builder similar to withKeyspace and other methods.

 

SocketOptions	setConnectTimeoutMillis(int connectTimeoutMillis) Sets the connection timeout in milliseconds.
SocketOptions	setKeepAlive(boolean keepAlive) Sets whether to enable TCP keepalive.
SocketOptions	setReadTimeoutMillis(int readTimeoutMillis) Sets the per-host read timeout in milliseconds.
SocketOptions	setReceiveBufferSize(int receiveBufferSize) Sets a hint to the size of the underlying buffers for incoming network I/O.
SocketOptions	setReuseAddress(boolean reuseAddress) Sets whether to enable reuse-address.
SocketOptions	setSendBufferSize(int sendBufferSize) Sets a hint to the size of the underlying buffers for outgoing network I/O.
SocketOptions	setSoLinger(int soLinger) Sets the linger-on-close timeout.
SocketOptions	setTcpNoDelay(boolean tcpNoDelay) Sets whether to disable Nagle's algorithm.

Issue Links

• links to: GitHub Pull Request #11732