Reference documentation and code samples for the Dataflow V1beta3 API class Google::Cloud::Dataflow::V1beta3::PubsubLocation.
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.