Package com.google.dataflow.v1beta3
Interface PubsubLocationOrBuilder
-
- All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder
- All Known Implementing Classes:
PubsubLocation,PubsubLocation.Builder
public interface PubsubLocationOrBuilder extends com.google.protobuf.MessageOrBuilder
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleangetDropLateData()Indicates whether the pipeline allows late-arriving data.StringgetIdLabel()If set, contains a pubsub label from which to extract record ids.com.google.protobuf.ByteStringgetIdLabelBytes()If set, contains a pubsub label from which to extract record ids.StringgetSubscription()A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"com.google.protobuf.ByteStringgetSubscriptionBytes()A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"StringgetTimestampLabel()If set, contains a pubsub label from which to extract record timestamps.com.google.protobuf.ByteStringgetTimestampLabelBytes()If set, contains a pubsub label from which to extract record timestamps.StringgetTopic()A pubsub topic, in the form of "pubsub.googleapis.com/topics/<project-id>/<topic-name>"com.google.protobuf.ByteStringgetTopicBytes()A pubsub topic, in the form of "pubsub.googleapis.com/topics/<project-id>/<topic-name>"StringgetTrackingSubscription()If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.com.google.protobuf.ByteStringgetTrackingSubscriptionBytes()If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.booleangetWithAttributes()If true, then the client has requested to get pubsub attributes.-
Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
-
-
-
Method Detail
-
getTopic
String getTopic()
A pubsub topic, in the form of "pubsub.googleapis.com/topics/<project-id>/<topic-name>"
string topic = 1;- Returns:
- The topic.
-
getTopicBytes
com.google.protobuf.ByteString getTopicBytes()
A pubsub topic, in the form of "pubsub.googleapis.com/topics/<project-id>/<topic-name>"
string topic = 1;- Returns:
- The bytes for topic.
-
getSubscription
String getSubscription()
A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
string subscription = 2;- Returns:
- The subscription.
-
getSubscriptionBytes
com.google.protobuf.ByteString getSubscriptionBytes()
A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
string subscription = 2;- Returns:
- The bytes for subscription.
-
getTimestampLabel
String getTimestampLabel()
If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.
string timestamp_label = 3;- Returns:
- The timestampLabel.
-
getTimestampLabelBytes
com.google.protobuf.ByteString getTimestampLabelBytes()
If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.
string timestamp_label = 3;- Returns:
- The bytes for timestampLabel.
-
getIdLabel
String getIdLabel()
If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.
string id_label = 4;- Returns:
- The idLabel.
-
getIdLabelBytes
com.google.protobuf.ByteString getIdLabelBytes()
If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.
string id_label = 4;- Returns:
- The bytes for idLabel.
-
getDropLateData
boolean getDropLateData()
Indicates whether the pipeline allows late-arriving data.
bool drop_late_data = 5;- Returns:
- The dropLateData.
-
getTrackingSubscription
String getTrackingSubscription()
If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.
string tracking_subscription = 6;- Returns:
- The trackingSubscription.
-
getTrackingSubscriptionBytes
com.google.protobuf.ByteString getTrackingSubscriptionBytes()
If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.
string tracking_subscription = 6;- Returns:
- The bytes for trackingSubscription.
-
getWithAttributes
boolean getWithAttributes()
If true, then the client has requested to get pubsub attributes.
bool with_attributes = 7;- Returns:
- The withAttributes.
-
-