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

Class RunnerImplementedSource

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

@Internal
public class RunnerImplementedSource
extends PTransform<PBegin,PCollection<byte[]>>

See Also:

Serialized Form

Field Summary

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

name

Constructor Summary

Constructors

Constructor and Description
RunnerImplementedSource(PubsubUnboundedSource source)

Method Summary

Modifier and Type	Method and Description
PCollection<byte[]>	expand(PBegin 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).
PubsubUnboundedSource	getOverriddenSource()
ValueProvider<PubsubClient.SubscriptionPath>	getSubscriptionProvider()
java.lang.String	getTimestampAttribute()
ValueProvider<PubsubClient.TopicPath>	getTopicProvider()
boolean	isWithAttributes()

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

RunnerImplementedSource

public RunnerImplementedSource(PubsubUnboundedSource source)

Method Detail

getOverriddenSource

public PubsubUnboundedSource getOverriddenSource()

getTopicProvider

public ValueProvider<PubsubClient.TopicPath> getTopicProvider()

getSubscriptionProvider

public ValueProvider<PubsubClient.SubscriptionPath> getSubscriptionProvider()

getTimestampAttribute

public java.lang.String getTimestampAttribute()

getIdAttribute

public java.lang.String getIdAttribute()

isWithAttributes

public boolean isWithAttributes()

expand

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

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<PBegin,PCollection<byte[]>>