Nathan Fisher created BEAM-10017:
------------------------------------
Summary: Expose SocketOptions timeouts in CassandraIO builder
Key: BEAM-10017
URL: https://issues.apache.org/jira/browse/BEAM-10017
Project: Beam
Issue Type: Improvement
Components: io-java-cassandra
Reporter: Nathan Fisher
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|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html]}}|{{[setConnectTimeoutMillis|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html#setConnectTimeoutMillis-int-](int
connectTimeoutMillis)}}
Sets the connection timeout in milliseconds.|
|{{[SocketOptions|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html]}}|{{[setKeepAlive|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html#setKeepAlive-boolean-](boolean
keepAlive)}}
Sets whether to enable TCP keepalive.|
|{{[SocketOptions|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html]}}|{{[setReadTimeoutMillis|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html#setReadTimeoutMillis-int-](int
readTimeoutMillis)}}
Sets the per-host read timeout in milliseconds.|
|{{[SocketOptions|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html]}}|{{[setReceiveBufferSize|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html#setReceiveBufferSize-int-](int
receiveBufferSize)}}
Sets a hint to the size of the underlying buffers for incoming network I/O.|
|{{[SocketOptions|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html]}}|{{[setReuseAddress|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html#setReuseAddress-boolean-](boolean
reuseAddress)}}
Sets whether to enable reuse-address.|
|{{[SocketOptions|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html]}}|{{[setSendBufferSize|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html#setSendBufferSize-int-](int
sendBufferSize)}}
Sets a hint to the size of the underlying buffers for outgoing network I/O.|
|{{[SocketOptions|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html]}}|{{[setSoLinger|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html#setSoLinger-int-](int
soLinger)}}
Sets the linger-on-close timeout.|
|{{[SocketOptions|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html]}}|{{[setTcpNoDelay|https://docs.datastax.com/en/drivers/java/3.8/com/datastax/driver/core/SocketOptions.html#setTcpNoDelay-boolean-](boolean
tcpNoDelay)}}
Sets whether to disable Nagle's algorithm.|
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
