[ https://issues.apache.org/jira/browse/BEAM-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Etienne Chauchot updated BEAM-10017: ------------------------------------ Summary: Expose SocketOptions timeouts in CassandraIO (was: Expose SocketOptions timeouts in CassandraIO builder) > Expose SocketOptions timeouts in CassandraIO > -------------------------------------------- > > Key: BEAM-10017 > URL: https://issues.apache.org/jira/browse/BEAM-10017 > Project: Beam > Issue Type: Improvement > Components: io-java-cassandra > Reporter: Nathan Fisher > Priority: P3 > Time Spent: 50m > Remaining Estimate: 0h > > 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)