public sealed class PubsubLocation : IMessage<PubsubLocation>, IEquatable<PubsubLocation>, IDeepCloneable<PubsubLocation>, IBufferMessage, IMessage
Reference documentation and code samples for the Dataflow v1beta3 API class PubsubLocation.
Identifies a pubsub location to use for transferring data into or out of a streaming Dataflow job.
Implements
IMessagePubsubLocation, IEquatablePubsubLocation, IDeepCloneablePubsubLocation, IBufferMessage, IMessageNamespace
Google.Cloud.Dataflow.V1Beta3Assembly
Google.Cloud.Dataflow.V1Beta3.dll
Constructors
PubsubLocation()
public PubsubLocation()
PubsubLocation(PubsubLocation)
public PubsubLocation(PubsubLocation other)
Parameter | |
---|---|
Name | Description |
other |
PubsubLocation |
Properties
DropLateData
public bool DropLateData { get; set; }
Indicates whether the pipeline allows late-arriving data.
Property Value | |
---|---|
Type | Description |
bool |
IdLabel
public string IdLabel { get; set; }
If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.
Property Value | |
---|---|
Type | Description |
string |
Subscription
public string Subscription { get; set; }
A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
Property Value | |
---|---|
Type | Description |
string |
TimestampLabel
public string TimestampLabel { get; set; }
If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.
Property Value | |
---|---|
Type | Description |
string |
Topic
public string Topic { get; set; }
A pubsub topic, in the form of "pubsub.googleapis.com/topics/<project-id>/<topic-name>"
Property Value | |
---|---|
Type | Description |
string |
TrackingSubscription
public string TrackingSubscription { get; set; }
If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.
Property Value | |
---|---|
Type | Description |
string |
WithAttributes
public bool WithAttributes { get; set; }
If true, then the client has requested to get pubsub attributes.
Property Value | |
---|---|
Type | Description |
bool |