class Google::Apis::DataflowV1b3::PubsubLocation

Identifies a pubsub location to use for transferring data into or out of a streaming Dataflow job.

Attributes

drop_late_data[RW]

Indicates whether the pipeline allows late-arriving data. Corresponds to the JSON property `dropLateData` @return [Boolean]

drop_late_data?[RW]

Indicates whether the pipeline allows late-arriving data. Corresponds to the JSON property `dropLateData` @return [Boolean]

id_label[RW]

If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort. Corresponds to the JSON property `idLabel` @return [String]

subscription[RW]

A pubsub subscription, in the form of “pubsub.googleapis.com/subscriptions//” Corresponds to the JSON property `subscription` @return [String]

timestamp_label[RW]

If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival. Corresponds to the JSON property `timestampLabel` @return [String]

topic[RW]

A pubsub topic, in the form of “pubsub.googleapis.com/topics//” Corresponds to the JSON property `topic` @return [String]

tracking_subscription[RW]

If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation. Corresponds to the JSON property `trackingSubscription` @return [String]

with_attributes[RW]

If true, then the client has requested to get pubsub attributes. Corresponds to the JSON property `withAttributes` @return [Boolean]

with_attributes?[RW]

If true, then the client has requested to get pubsub attributes. Corresponds to the JSON property `withAttributes` @return [Boolean]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 3607
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

Update properties of this object

# File lib/google/apis/dataflow_v1b3/classes.rb, line 3612
def update!(**args)
  @drop_late_data = args[:drop_late_data] if args.key?(:drop_late_data)
  @id_label = args[:id_label] if args.key?(:id_label)
  @subscription = args[:subscription] if args.key?(:subscription)
  @timestamp_label = args[:timestamp_label] if args.key?(:timestamp_label)
  @topic = args[:topic] if args.key?(:topic)
  @tracking_subscription = args[:tracking_subscription] if args.key?(:tracking_subscription)
  @with_attributes = args[:with_attributes] if args.key?(:with_attributes)
end