public sealed class PubsubLocation : IMessage<PubsubLocation>, IEquatable<PubsubLocation>, IDeepCloneable<PubsubLocation>, IBufferMessage, IMessageReference 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 |
|
DynamicDestinations
public bool DynamicDestinations { get; set; }If true, then this location represents dynamic topics.
| 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 |
|