Class PubsubLocation (1.0.0-beta03) 

public sealed class PubsubLocation : IMessage<PubsubLocation>, IEquatable<PubsubLocation>, IDeepCloneable<PubsubLocation>, IBufferMessage, IMessage

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
Boolean

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
Boolean