Dataflow v1beta3 API - Class PubsubLocation (2.0.0-beta06)

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.

Inheritance

object > PubsubLocation

Namespace

Google.Cloud.Dataflow.V1Beta3

Assembly

Google.Cloud.Dataflow.V1Beta3.dll

Constructors

PubsubLocation()

public PubsubLocation()

PubsubLocation(PubsubLocation)

public PubsubLocation(PubsubLocation other)
Parameter
NameDescription
otherPubsubLocation

Properties

DropLateData

public bool DropLateData { get; set; }

Indicates whether the pipeline allows late-arriving data.

Property Value
TypeDescription
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
TypeDescription
string

Subscription

public string Subscription { get; set; }

A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"

Property Value
TypeDescription
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
TypeDescription
string

Topic

public string Topic { get; set; }

A pubsub topic, in the form of "pubsub.googleapis.com/topics/<project-id>/<topic-name>"

Property Value
TypeDescription
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
TypeDescription
string

WithAttributes

public bool WithAttributes { get; set; }

If true, then the client has requested to get pubsub attributes.

Property Value
TypeDescription
bool