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>

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

annotations, displayData, name, resourceHints

Constructor Summary

Constructors

Constructor	Description
WriteStreams()

Method Summary

Modifier and Type	Method	Description
PDone	expand(PCollection<KV<String,Map<String,String>>> input)	Override this method to specify how this PTransform should be expanded on the given InputT.
abstract org.apache.beam.sdk.io.redis.RedisIO.WriteStreams.Builder	toBuilder()
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.
RedisIO.WriteStreams	withConnectionConfiguration(RedisConnectionConfiguration connection)
RedisIO.WriteStreams	withEndpoint(String host, int port)
RedisIO.WriteStreams	withMaxLen(long maxLen)

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

WriteStreams

public WriteStreams()

Method Details

toBuilder

public abstract org.apache.beam.sdk.io.redis.RedisIO.WriteStreams.Builder toBuilder()

withMaxLen

public RedisIO.WriteStreams withMaxLen(long maxLen)

withEndpoint

public RedisIO.WriteStreams withEndpoint(String host,
 int port)

withConnectionConfiguration

public RedisIO.WriteStreams withConnectionConfiguration(RedisConnectionConfiguration connection)

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>