Reference documentation and code samples for the Google Cloud Dataflow V1beta3 Client class PubsubLocation.
Identifies a pubsub location to use for transferring data into or out of a streaming Dataflow job.
Generated from protobuf message google.dataflow.v1beta3.PubsubLocation
Namespace
Google \ Cloud \ Dataflow \ V1beta3Methods
__construct
Constructor.
data
array
Optional. Data for populating the Message object.
↳ topic
string
A pubsub topic, in the form of "pubsub.googleapis.com/topics/
↳ subscription
string
A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/
↳ timestamp_label
string
If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.
↳ id_label
string
If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.
↳ drop_late_data
bool
Indicates whether the pipeline allows late-arriving data.
↳ tracking_subscription
string
If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.
↳ with_attributes
bool
If true, then the client has requested to get pubsub attributes.
↳ dynamic_destinations
bool
If true, then this location represents dynamic topics.
getTopic
A pubsub topic, in the form of "pubsub.googleapis.com/topics/
string
setTopic
A pubsub topic, in the form of "pubsub.googleapis.com/topics/
var
string
$this
getSubscription
A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/
string
setSubscription
A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/
var
string
$this
getTimestampLabel
If set, contains a pubsub label from which to extract record timestamps.
If left empty, record timestamps will be generated upon arrival.
string
setTimestampLabel
If set, contains a pubsub label from which to extract record timestamps.
If left empty, record timestamps will be generated upon arrival.
var
string
$this
getIdLabel
If set, contains a pubsub label from which to extract record ids.
If left empty, record deduplication will be strictly best effort.
string
setIdLabel
If set, contains a pubsub label from which to extract record ids.
If left empty, record deduplication will be strictly best effort.
var
string
$this
getDropLateData
Indicates whether the pipeline allows late-arriving data.
bool
setDropLateData
Indicates whether the pipeline allows late-arriving data.
var
bool
$this
getTrackingSubscription
If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.
string
setTrackingSubscription
If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.
var
string
$this
getWithAttributes
If true, then the client has requested to get pubsub attributes.
bool
setWithAttributes
If true, then the client has requested to get pubsub attributes.
var
bool
$this
getDynamicDestinations
If true, then this location represents dynamic topics.
bool
setDynamicDestinations
If true, then this location represents dynamic topics.
var
bool
$this
