Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-10017

Expose SocketOptions timeouts in CassandraIO

Details

    • Improvement
    • Status: Resolved
    • P3
    • Resolution: Fixed
    • None
    • 2.23.0
    • io-java-cassandra
    • None

    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.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              nfisher@junctionbox.ca Nathan Fisher
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 3h 50m
                  3h 50m