PubsubLocation class

Identifies a pubsub location to use for transferring data into or out of a streaming Dataflow job.

Constructors

PubsubLocation({bool? dropLateData, bool? dynamicDestinations, String? idLabel, String? subscription, String? timestampLabel, String? topic, String? trackingSubscription, bool? withAttributes})

PubsubLocation.fromJson(Map json_)

Properties

dropLateData ↔ bool?

Indicates whether the pipeline allows late-arriving data.

getter/setter pair

dynamicDestinations ↔ bool?

If true, then this location represents dynamic topics.

getter/setter pair

hashCode → int

The hash code for this object.

no setter, inherited

idLabel ↔ String?

If set, contains a pubsub label from which to extract record ids.

getter/setter pair

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

subscription ↔ String?

A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions//"

getter/setter pair

timestampLabel ↔ String?

If set, contains a pubsub label from which to extract record timestamps.

getter/setter pair

topic ↔ String?

A pubsub topic, in the form of "pubsub.googleapis.com/topics//"

getter/setter pair

trackingSubscription ↔ String?

If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.

getter/setter pair

withAttributes ↔ bool?

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

getter/setter pair

Methods

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

toJson() → Map<String, dynamic>

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited