[
https://issues.apache.org/jira/browse/BEAM-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111164#comment-17111164
]
Nathan Fisher edited comment on BEAM-10017 at 5/19/20, 1:19 PM:
----------------------------------------------------------------
No problem!
Habit from work, most everything is discussed/proposed in a PR.
Will add those when I have some free time and where it makes sense:
- Connect to writer/reader.
- Read to the reader.
What's the equivalent of `mvn install` for this project so that I can test the
jar locally? I read the contribution and found this reference below for
checking the module but didn't see a reference to build a jar.
{{./gradlew -p sdks/java/io/cassandra check}}
was (Author: [email protected]):
No problem!
Habit from work, most everything is discussed/proposed in a PR.
Will add those when I have some free time and where it makes sense:
- Connect to writer/reader.
- Read to the reader.
What's the equivalent of `mvn install` for this project so that I can test the
jar locally? I read the contribution and found this reference below for
checking the module but didn't see a reference to build a jar.
{{./gradlew -p sdks/java/io/cassandra check}}
{{}}
> 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)
