Class: Google::Cloud::Dataflow::V1beta3::PubsubLocation

Inherits:

Object

• Object
• Google::Cloud::Dataflow::V1beta3::PubsubLocation

Extended by:

Protobuf::MessageExts::ClassMethods

Includes:

Protobuf::MessageExts

Defined in:

proto_docs/google/dataflow/v1beta3/streaming.rb

Overview

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

Instance Attribute Summary

• #drop_late_data ⇒ ::Boolean

  Indicates whether the pipeline allows late-arriving data.

• #dynamic_destinations ⇒ ::Boolean

  If true, then this location represents dynamic topics.

• #id_label ⇒ ::String

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

• #subscription ⇒ ::String

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

• #timestamp_label ⇒ ::String

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

• #topic ⇒ ::String

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

• #tracking_subscription ⇒ ::String

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

• #with_attributes ⇒ ::Boolean

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

Instance Attribute Details

#drop_late_data ⇒ ::Boolean

# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 86

class PubsubLocation
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#dynamic_destinations ⇒ ::Boolean

# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 86

class PubsubLocation
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#id_label ⇒ ::String

# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 86

class PubsubLocation
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#subscription ⇒ ::String

# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 86

class PubsubLocation
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#timestamp_label ⇒ ::String

# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 86

class PubsubLocation
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#topic ⇒ ::String

# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 86

class PubsubLocation
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#tracking_subscription ⇒ ::String

# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 86

class PubsubLocation
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#with_attributes ⇒ ::Boolean

# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 86

class PubsubLocation
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end