public static class PubsubIO.Write.Bound extends PTransform<PCollection<java.lang.String>,PDone>
PCollection<String>
to a PubSub stream.name| Modifier and Type | Method and Description |
|---|---|
PDone |
apply(PCollection<java.lang.String> input)
Applies this
PTransform on the given Input, and returns its
Output. |
protected Coder<java.lang.Void> |
getDefaultOutputCoder()
Returns the default
Coder to use for the output of this
single-output PTransform, or null if
none can be inferred. |
java.lang.String |
getIdLabel() |
protected java.lang.String |
getKindString()
Returns a string describing what kind of
PTransform this is. |
java.lang.String |
getTimestampLabel() |
java.lang.String |
getTopic() |
PubsubIO.Write.Bound |
idLabel(java.lang.String idLabel)
Returns a new PubsubIO.Write PTransform that's like this one but publishing record ids
to the given PubSub label.
|
PubsubIO.Write.Bound |
named(java.lang.String name)
Returns a new PubsubIO.Write PTransform that's like this one but with the given step
name.
|
PubsubIO.Write.Bound |
timestampLabel(java.lang.String timestampLabel)
Returns a new PubsubIO.Write PTransform that's like this one but publishing timestamps
to the given PubSub label.
|
PubsubIO.Write.Bound |
topic(java.lang.String topic)
Returns a new PubsubIO.Write PTransform that's like this one but writing to the given
topic.
|
finishSpecifying, getCoderRegistry, getDefaultName, getDefaultOutputCoder, getInput, getName, getOutput, getPipeline, setName, setPipeline, toString, withNamepublic PubsubIO.Write.Bound named(java.lang.String name)
public PubsubIO.Write.Bound topic(java.lang.String topic)
public PubsubIO.Write.Bound timestampLabel(java.lang.String timestampLabel)
public PubsubIO.Write.Bound idLabel(java.lang.String idLabel)
public PDone apply(PCollection<java.lang.String> input)
PTransformPTransform on the given Input, and returns its
Output.
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).
The default implementation throws an exception. A derived class must
either implement apply, or else each runner must supply a custom
implementation via
PipelineRunner.apply(com.google.cloud.dataflow.sdk.transforms.PTransform<Input, Output>, Input).
apply in class PTransform<PCollection<java.lang.String>,PDone>protected Coder<java.lang.Void> getDefaultOutputCoder()
PTransformCoder to use for the output of this
single-output PTransform, or null if
none can be inferred.
By default, returns null.
getDefaultOutputCoder in class PTransform<PCollection<java.lang.String>,PDone>protected java.lang.String getKindString()
PTransformPTransform this is.
By default, returns the base name of this
PTransform's class.
getKindString in class PTransform<PCollection<java.lang.String>,PDone>public java.lang.String getTopic()
public java.lang.String getTimestampLabel()
public java.lang.String getIdLabel()