Package org.apache.beam.sdk.io.redis

Class RedisIO.WriteStreams

java.lang.Object
org.apache.beam.sdk.transforms.PTransform<PCollection<KV<String,Map<String,String>>>,PDone>
org.apache.beam.sdk.io.redis.RedisIO.WriteStreams
All Implemented Interfaces:
Serializable, HasDisplayData
Enclosing class:
RedisIO
public abstract static class RedisIO.WriteStreams extends PTransform<PCollection<KV<String,Map<String,String>>>,PDone>
A PTransform to write stream key pairs (https://redis.io/topics/streams-intro) to a Redis server.
See Also:

  • Constructor Details

    • WriteStreams

      public WriteStreams()

  • Method Details

    • withEndpoint

      public RedisIO.WriteStreams withEndpoint(String host, int port)
      Set the hostname and port of the Redis server to connect to.

    • withAuth

      public RedisIO.WriteStreams withAuth(String auth)
      Use the redis AUTH command when connecting to the server; the format of the string can be either just a password or a username and password separated by a space. See https://redis.io/commands/auth for details

    • withTimeout

      public RedisIO.WriteStreams withTimeout(int timeout)
      Set the connection timeout for the Redis server connection.

    • withConnectionConfiguration

      public RedisIO.WriteStreams withConnectionConfiguration(RedisConnectionConfiguration connection)
      Predefine a RedisConnectionConfiguration and pass it to the builder.

    • withMaxLen

      public RedisIO.WriteStreams withMaxLen(long maxLen)
      When appending (XADD) to a stream, set a MAXLEN option.

    • withApproximateTrim

      public RedisIO.WriteStreams withApproximateTrim(boolean approximateTrim)
      If withMaxLen(long) is used, set the "~" prefix to the MAXLEN value, indicating to the server that it should use "close enough" trimming.

    • expand

      public PDone expand(PCollection<KV<String,Map<String,String>>> input)
      Description copied from class: PTransform
      Override this method to specify how this PTransform should be expanded on the given InputT.

      NOTE: This method should not be called directly. Instead apply the PTransform should be applied to the InputT using the apply method.

      Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).

      Specified by:
      expand in class PTransform<PCollection<KV<String,Map<String,String>>>,PDone>