Class ExternalWrite.Configuration
- java.lang.Object
-
- org.apache.beam.sdk.io.gcp.pubsub.ExternalWrite.Configuration
-
- Enclosing class:
- ExternalWrite
public static class ExternalWrite.Configuration extends java.lang.ObjectParameters class to expose the transform to an external SDK.
-
-
Constructor Summary
Constructors Constructor Description Configuration()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidsetIdLabel(@Nullable java.lang.String idAttribute)voidsetPublishWithOrderingKey(java.lang.Boolean publishWithOrderingKey)voidsetTimestampAttribute(@Nullable java.lang.String timestampAttribute)voidsetTopic(java.lang.String topic)
-
-
-
Method Detail
-
setTopic
public void setTopic(java.lang.String topic)
-
setIdLabel
public void setIdLabel(@Nullable java.lang.String idAttribute)
-
setTimestampAttribute
public void setTimestampAttribute(@Nullable java.lang.String timestampAttribute)
-
setPublishWithOrderingKey
public void setPublishWithOrderingKey(java.lang.Boolean publishWithOrderingKey)
-
-