Class Google::Cloud::Dataflow::V1beta3::PubsubLocation (v0.2.0)

Stay organized with collections Save and categorize content based on your preferences.

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

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#drop_late_data

def drop_late_data() -> ::Boolean
Returns
  • (::Boolean) — Indicates whether the pipeline allows late-arriving data.

#drop_late_data=

def drop_late_data=(value) -> ::Boolean
Parameter
  • value (::Boolean) — Indicates whether the pipeline allows late-arriving data.
Returns
  • (::Boolean) — Indicates whether the pipeline allows late-arriving data.

#id_label

def id_label() -> ::String
Returns
  • (::String) — If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.

#id_label=

def id_label=(value) -> ::String
Parameter
  • value (::String) — If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.
Returns
  • (::String) — If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.

#subscription

def subscription() -> ::String
Returns
  • (::String) — A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/

#subscription=

def subscription=(value) -> ::String
Parameter
  • value (::String) — A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/
Returns
  • (::String) — A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/

#timestamp_label

def timestamp_label() -> ::String
Returns
  • (::String) — If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.

#timestamp_label=

def timestamp_label=(value) -> ::String
Parameter
  • value (::String) — If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.
Returns
  • (::String) — If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.

#topic

def topic() -> ::String
Returns
  • (::String) — A pubsub topic, in the form of "pubsub.googleapis.com/topics/

#topic=

def topic=(value) -> ::String
Parameter
  • value (::String) — A pubsub topic, in the form of "pubsub.googleapis.com/topics/
Returns
  • (::String) — A pubsub topic, in the form of "pubsub.googleapis.com/topics/

#tracking_subscription

def tracking_subscription() -> ::String
Returns
  • (::String) — If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.

#tracking_subscription=

def tracking_subscription=(value) -> ::String
Parameter
  • value (::String) — If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.
Returns
  • (::String) — If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.

#with_attributes

def with_attributes() -> ::Boolean
Returns
  • (::Boolean) — If true, then the client has requested to get pubsub attributes.

#with_attributes=

def with_attributes=(value) -> ::Boolean
Parameter
  • value (::Boolean) — If true, then the client has requested to get pubsub attributes.
Returns
  • (::Boolean) — If true, then the client has requested to get pubsub attributes.