Class: Google::Apis::DataflowV1b3::PubsubLocation

Inherits:
Object
  • Object
show all
Includes:
Core::Hashable, Core::JsonObjectSupport
Defined in:
lib/google/apis/dataflow_v1b3/classes.rb,
lib/google/apis/dataflow_v1b3/representations.rb,
lib/google/apis/dataflow_v1b3/representations.rb

Overview

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ PubsubLocation

Returns a new instance of PubsubLocation.



4207
4208
4209
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4207

def initialize(**args)
   update!(**args)
end

Instance Attribute Details

#drop_late_data ⇒ Boolean Also known as: drop_late_data?

Indicates whether the pipeline allows late-arriving data. Corresponds to the JSON property dropLateData

Returns:

  • (Boolean) 


4164
4165
4166
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4164

def drop_late_data
  @drop_late_data
end

#dynamic_destinations ⇒ Boolean Also known as: dynamic_destinations?

If true, then this location represents dynamic topics. Corresponds to the JSON property dynamicDestinations

Returns:

  • (Boolean) 


4170
4171
4172
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4170

def dynamic_destinations
  @dynamic_destinations
end

#id_label ⇒ String

If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort. Corresponds to the JSON property idLabel

Returns:

  • (String) 


4177
4178
4179
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4177

def id_label
  @id_label
end

#subscription ⇒ String

A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions//" Corresponds to the JSON property subscription

Returns:

  • (String) 


4182
4183
4184
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4182

def subscription
  @subscription
end

#timestamp_label ⇒ String

If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival. Corresponds to the JSON property timestampLabel

Returns:

  • (String) 


4188
4189
4190
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4188

def timestamp_label
  @timestamp_label
end

#topic ⇒ String

A pubsub topic, in the form of "pubsub.googleapis.com/topics//" Corresponds to the JSON property topic

Returns:

  • (String) 


4193
4194
4195
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4193

def topic
  @topic
end

#tracking_subscription ⇒ String

If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation. Corresponds to the JSON property trackingSubscription

Returns:

  • (String) 


4199
4200
4201
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4199

def tracking_subscription
  @tracking_subscription
end

#with_attributes ⇒ Boolean Also known as: with_attributes?

If true, then the client has requested to get pubsub attributes. Corresponds to the JSON property withAttributes

Returns:

  • (Boolean) 


4204
4205
4206
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4204

def with_attributes
  @with_attributes
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



4212
4213
4214
4215
4216
4217
4218
4219
4220
4221
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 4212

def update!(**args)
  @drop_late_data = args[:drop_late_data] if args.key?(:drop_late_data)
  @dynamic_destinations = args[:dynamic_destinations] if args.key?(:dynamic_destinations)
  @id_label = args[:id_label] if args.key?(:id_label)
  @subscription = args[:subscription] if args.key?(:subscription)
  @timestamp_label = args[:timestamp_label] if args.key?(:timestamp_label)
  @topic = args[:topic] if args.key?(:topic)
  @tracking_subscription = args[:tracking_subscription] if args.key?(:tracking_subscription)
  @with_attributes = args[:with_attributes] if args.key?(:with_attributes)
end