org.apache.beam.sdk.io.gcp.pubsub

Class RunnerImplementedSink

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<PCollection<byte[]>,PDone>

org.apache.beam.sdk.io.gcp.pubsub.RunnerImplementedSink

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

@Internal
public class RunnerImplementedSink
extends PTransform<PCollection<byte[]>,PDone>

See Also:

Serialized Form

Field Summary

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

name

Constructor Summary

Constructors

Constructor and Description
RunnerImplementedSink(PubsubUnboundedSink sink)

Method Summary

Modifier and Type	Method and Description
PDone	expand(PCollection<byte[]> input) Override this method to specify how this PTransform should be expanded on the given InputT.
java.lang.String	getIdAttribute()
protected java.lang.String	getKindString() Returns the name to use by default for this PTransform (not including the names of any enclosing PTransforms).
PubsubUnboundedSink	getOverrideSink()
java.lang.String	getTimestampAttribute()
ValueProvider<PubsubClient.TopicPath>	getTopicProvider()

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

compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getName, populateDisplayData, toString, validate

Methods inherited from class java.lang.Object

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

Constructor Detail

RunnerImplementedSink

public RunnerImplementedSink(PubsubUnboundedSink sink)

Method Detail

getOverrideSink

public PubsubUnboundedSink getOverrideSink()

getTopicProvider

public ValueProvider<PubsubClient.TopicPath> getTopicProvider()

getTimestampAttribute

public java.lang.String getTimestampAttribute()

getIdAttribute

public java.lang.String getIdAttribute()

expand

public PDone expand(PCollection<byte[]> 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<byte[]>,PDone>

getKindString

protected java.lang.String getKindString()

Description copied from class: PTransform

Returns the name to use by default for this PTransform (not including the names of any enclosing PTransforms).

By default, returns the base name of this PTransform's class.

The caller is responsible for ensuring that names of applied PTransforms are unique, e.g., by adding a uniquifying suffix when needed.

Overrides:

getKindString in class PTransform<PCollection<byte[]>,PDone>