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 boolean
getDropLateData()
Indicates whether the pipeline allows late-arriving data.String
getIdLabel()
If set, contains a pubsub label from which to extract record ids.com.google.protobuf.ByteString
getIdLabelBytes()
If set, contains a pubsub label from which to extract record ids.String
getSubscription()
A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"com.google.protobuf.ByteString
getSubscriptionBytes()
A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"String
getTimestampLabel()
If set, contains a pubsub label from which to extract record timestamps.com.google.protobuf.ByteString
getTimestampLabelBytes()
If set, contains a pubsub label from which to extract record timestamps.String
getTopic()
A pubsub topic, in the form of "pubsub.googleapis.com/topics/<project-id>/<topic-name>"com.google.protobuf.ByteString
getTopicBytes()
A pubsub topic, in the form of "pubsub.googleapis.com/topics/<project-id>/<topic-name>"String
getTrackingSubscription()
If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.com.google.protobuf.ByteString
getTrackingSubscriptionBytes()
If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.boolean
getWithAttributes()
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.
-
-