Package com.google.dataflow.v1beta3

Class PubsubLocation.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<PubsubLocation.Builder>
com.google.dataflow.v1beta3.PubsubLocation.Builder
All Implemented Interfaces:
PubsubLocationOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
PubsubLocation
public static final class PubsubLocation.Builder extends com.google.protobuf.GeneratedMessage.Builder<PubsubLocation.Builder> implements PubsubLocationOrBuilder
 Identifies a pubsub location to use for transferring data into or
 out of a streaming Dataflow job.
Protobuf type google.dataflow.v1beta3.PubsubLocation

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<PubsubLocation.Builder>

    • clear

      public PubsubLocation.Builder clear()
      Specified by:
      clear in interface com.google.protobuf.Message.Builder
      Specified by:
      clear in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clear in class com.google.protobuf.GeneratedMessage.Builder<PubsubLocation.Builder>

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<PubsubLocation.Builder>

    • getDefaultInstanceForType

      public PubsubLocation getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

    • build

      public PubsubLocation build()
      Specified by:
      build in interface com.google.protobuf.Message.Builder
      Specified by:
      build in interface com.google.protobuf.MessageLite.Builder

    • buildPartial

      public PubsubLocation buildPartial()
      Specified by:
      buildPartial in interface com.google.protobuf.Message.Builder
      Specified by:
      buildPartial in interface com.google.protobuf.MessageLite.Builder

    • mergeFrom

      public PubsubLocation.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<PubsubLocation.Builder>

    • mergeFrom

      public PubsubLocation.Builder mergeFrom(PubsubLocation other)

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage.Builder<PubsubLocation.Builder>

    • mergeFrom

      public PubsubLocation.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<PubsubLocation.Builder>
      Throws:
      IOException

    • getTopic

      public String getTopic()
       A pubsub topic, in the form of
 "pubsub.googleapis.com/topics/<project-id>/<topic-name>"
      string topic = 1;
      Specified by:
      getTopic in interface PubsubLocationOrBuilder
      Returns:
      The topic.

    • getTopicBytes

      public com.google.protobuf.ByteString getTopicBytes()
       A pubsub topic, in the form of
 "pubsub.googleapis.com/topics/<project-id>/<topic-name>"
      string topic = 1;
      Specified by:
      getTopicBytes in interface PubsubLocationOrBuilder
      Returns:
      The bytes for topic.

    • setTopic

      public PubsubLocation.Builder setTopic(String value)
       A pubsub topic, in the form of
 "pubsub.googleapis.com/topics/<project-id>/<topic-name>"
      string topic = 1;
      Parameters:
      value - The topic to set.
      Returns:
      This builder for chaining.

    • clearTopic

      public PubsubLocation.Builder clearTopic()
       A pubsub topic, in the form of
 "pubsub.googleapis.com/topics/<project-id>/<topic-name>"
      string topic = 1;
      Returns:
      This builder for chaining.

    • setTopicBytes

      public PubsubLocation.Builder setTopicBytes(com.google.protobuf.ByteString value)
       A pubsub topic, in the form of
 "pubsub.googleapis.com/topics/<project-id>/<topic-name>"
      string topic = 1;
      Parameters:
      value - The bytes for topic to set.
      Returns:
      This builder for chaining.

    • getSubscription

      public String getSubscription()
       A pubsub subscription, in the form of
 "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
      string subscription = 2;
      Specified by:
      getSubscription in interface PubsubLocationOrBuilder
      Returns:
      The subscription.

    • getSubscriptionBytes

      public com.google.protobuf.ByteString getSubscriptionBytes()
       A pubsub subscription, in the form of
 "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
      string subscription = 2;
      Specified by:
      getSubscriptionBytes in interface PubsubLocationOrBuilder
      Returns:
      The bytes for subscription.

    • setSubscription

      public PubsubLocation.Builder setSubscription(String value)
       A pubsub subscription, in the form of
 "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
      string subscription = 2;
      Parameters:
      value - The subscription to set.
      Returns:
      This builder for chaining.

    • clearSubscription

      public PubsubLocation.Builder clearSubscription()
       A pubsub subscription, in the form of
 "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
      string subscription = 2;
      Returns:
      This builder for chaining.

    • setSubscriptionBytes

      public PubsubLocation.Builder setSubscriptionBytes(com.google.protobuf.ByteString value)
       A pubsub subscription, in the form of
 "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
      string subscription = 2;
      Parameters:
      value - The bytes for subscription to set.
      Returns:
      This builder for chaining.

    • getTimestampLabel

      public 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;
      Specified by:
      getTimestampLabel in interface PubsubLocationOrBuilder
      Returns:
      The timestampLabel.

    • getTimestampLabelBytes

      public 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;
      Specified by:
      getTimestampLabelBytes in interface PubsubLocationOrBuilder
      Returns:
      The bytes for timestampLabel.

    • setTimestampLabel

      public PubsubLocation.Builder setTimestampLabel(String value)
       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;
      Parameters:
      value - The timestampLabel to set.
      Returns:
      This builder for chaining.

    • clearTimestampLabel

      public PubsubLocation.Builder clearTimestampLabel()
       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:
      This builder for chaining.

    • setTimestampLabelBytes

      public PubsubLocation.Builder setTimestampLabelBytes(com.google.protobuf.ByteString value)
       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;
      Parameters:
      value - The bytes for timestampLabel to set.
      Returns:
      This builder for chaining.

    • getIdLabel

      public 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;
      Specified by:
      getIdLabel in interface PubsubLocationOrBuilder
      Returns:
      The idLabel.

    • getIdLabelBytes

      public 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;
      Specified by:
      getIdLabelBytes in interface PubsubLocationOrBuilder
      Returns:
      The bytes for idLabel.

    • setIdLabel

      public PubsubLocation.Builder setIdLabel(String value)
       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;
      Parameters:
      value - The idLabel to set.
      Returns:
      This builder for chaining.

    • clearIdLabel

      public PubsubLocation.Builder clearIdLabel()
       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:
      This builder for chaining.

    • setIdLabelBytes

      public PubsubLocation.Builder setIdLabelBytes(com.google.protobuf.ByteString value)
       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;
      Parameters:
      value - The bytes for idLabel to set.
      Returns:
      This builder for chaining.

    • getDropLateData

      public boolean getDropLateData()
       Indicates whether the pipeline allows late-arriving data.
      bool drop_late_data = 5;
      Specified by:
      getDropLateData in interface PubsubLocationOrBuilder
      Returns:
      The dropLateData.

    • setDropLateData

      public PubsubLocation.Builder setDropLateData(boolean value)
       Indicates whether the pipeline allows late-arriving data.
      bool drop_late_data = 5;
      Parameters:
      value - The dropLateData to set.
      Returns:
      This builder for chaining.

    • clearDropLateData

      public PubsubLocation.Builder clearDropLateData()
       Indicates whether the pipeline allows late-arriving data.
      bool drop_late_data = 5;
      Returns:
      This builder for chaining.

    • getTrackingSubscription

      public String getTrackingSubscription()
       If set, specifies the pubsub subscription that will be used for tracking
 custom time timestamps for watermark estimation.
      string tracking_subscription = 6;
      Specified by:
      getTrackingSubscription in interface PubsubLocationOrBuilder
      Returns:
      The trackingSubscription.

    • getTrackingSubscriptionBytes

      public 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;
      Specified by:
      getTrackingSubscriptionBytes in interface PubsubLocationOrBuilder
      Returns:
      The bytes for trackingSubscription.

    • setTrackingSubscription

      public PubsubLocation.Builder setTrackingSubscription(String value)
       If set, specifies the pubsub subscription that will be used for tracking
 custom time timestamps for watermark estimation.
      string tracking_subscription = 6;
      Parameters:
      value - The trackingSubscription to set.
      Returns:
      This builder for chaining.

    • clearTrackingSubscription

      public PubsubLocation.Builder clearTrackingSubscription()
       If set, specifies the pubsub subscription that will be used for tracking
 custom time timestamps for watermark estimation.
      string tracking_subscription = 6;
      Returns:
      This builder for chaining.

    • setTrackingSubscriptionBytes

      public PubsubLocation.Builder setTrackingSubscriptionBytes(com.google.protobuf.ByteString value)
       If set, specifies the pubsub subscription that will be used for tracking
 custom time timestamps for watermark estimation.
      string tracking_subscription = 6;
      Parameters:
      value - The bytes for trackingSubscription to set.
      Returns:
      This builder for chaining.

    • getWithAttributes

      public boolean getWithAttributes()
       If true, then the client has requested to get pubsub attributes.
      bool with_attributes = 7;
      Specified by:
      getWithAttributes in interface PubsubLocationOrBuilder
      Returns:
      The withAttributes.

    • setWithAttributes

      public PubsubLocation.Builder setWithAttributes(boolean value)
       If true, then the client has requested to get pubsub attributes.
      bool with_attributes = 7;
      Parameters:
      value - The withAttributes to set.
      Returns:
      This builder for chaining.

    • clearWithAttributes

      public PubsubLocation.Builder clearWithAttributes()
       If true, then the client has requested to get pubsub attributes.
      bool with_attributes = 7;
      Returns:
      This builder for chaining.

    • getDynamicDestinations

      public boolean getDynamicDestinations()
       If true, then this location represents dynamic topics.
      bool dynamic_destinations = 8;
      Specified by:
      getDynamicDestinations in interface PubsubLocationOrBuilder
      Returns:
      The dynamicDestinations.

    • setDynamicDestinations

      public PubsubLocation.Builder setDynamicDestinations(boolean value)
       If true, then this location represents dynamic topics.
      bool dynamic_destinations = 8;
      Parameters:
      value - The dynamicDestinations to set.
      Returns:
      This builder for chaining.

    • clearDynamicDestinations

      public PubsubLocation.Builder clearDynamicDestinations()
       If true, then this location represents dynamic topics.
      bool dynamic_destinations = 8;
      Returns:
      This builder for chaining.