google_api_dataflow v0.24.0 GoogleApi.Dataflow.V1b3.Model.PubsubLocation View Source

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

Attributes

dropLateData (type: boolean(), default: nil) - Indicates whether the pipeline allows late-arriving data.
idLabel (type: String.t, default: nil) - If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.
subscription (type: String.t, default: nil) - A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions//"
timestampLabel (type: String.t, default: nil) - If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.
topic (type: String.t, default: nil) - A pubsub topic, in the form of "pubsub.googleapis.com/topics//"
trackingSubscription (type: String.t, default: nil) - If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.
withAttributes (type: boolean(), default: nil) - If true, then the client has requested to get pubsub attributes.

Link to this section Summary

Types

t()

Functions

decode(value, options)

Unwrap a decoded JSON object into its complex fields.

Link to this section Types

t()

t() :: %GoogleApi.Dataflow.V1b3.Model.PubsubLocation{
  dropLateData: boolean(),
  idLabel: String.t(),
  subscription: String.t(),
  timestampLabel: String.t(),
  topic: String.t(),
  trackingSubscription: String.t(),
  withAttributes: boolean()
}

Link to this section Functions

decode(value, options)

decode(struct(), keyword()) :: struct()

Unwrap a decoded JSON object into its complex fields.