Package com.google.dataflow.v1beta3

Interface PubsubLocationOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
PubsubLocation, PubsubLocation.Builder
@Generated public interface PubsubLocationOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    getDropLateData()
    Indicates whether the pipeline allows late-arriving data.
    boolean
    getDynamicDestinations()
    If true, then this location represents dynamic topics.
    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.MessageLiteOrBuilder

    isInitialized

    Methods inherited from interface com.google.protobuf.MessageOrBuilder

    findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

  • Method Details

    • 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.

    • getDynamicDestinations

      boolean getDynamicDestinations()
       If true, then this location represents dynamic topics.
      bool dynamic_destinations = 8;
      Returns:
      The dynamicDestinations.