Class: Google::Apis::AnalyticshubV1::AvroConfig

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

Overview

Configuration for writing message data in Avro format. Message payloads and metadata will be written to files as an Avro binary.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ AvroConfig

Returns a new instance of AvroConfig.

[View source]

147
148
149
# File 'lib/google/apis/analyticshub_v1/classes.rb', line 147

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

Instance Attribute Details

#use_topic_schemaBoolean Also known as: use_topic_schema?

Optional. When true, the output Cloud Storage file will be serialized using the topic schema, if it exists. Corresponds to the JSON property useTopicSchema

Returns:

  • (Boolean)

134
135
136
# File 'lib/google/apis/analyticshub_v1/classes.rb', line 134

def use_topic_schema
  @use_topic_schema
end

#write_metadataBoolean Also known as: write_metadata?

Optional. When true, write the subscription name, message_id, publish_time, attributes, and ordering_key as additional fields in the output. The subscription name, message_id, and publish_time fields are put in their own fields while all other message properties other than data (for example, an ordering_key, if present) are added as entries in the attributes map. Corresponds to the JSON property writeMetadata

Returns:

  • (Boolean)

144
145
146
# File 'lib/google/apis/analyticshub_v1/classes.rb', line 144

def 
  @write_metadata
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object

[View source]

152
153
154
155
# File 'lib/google/apis/analyticshub_v1/classes.rb', line 152

def update!(**args)
  @use_topic_schema = args[:use_topic_schema] if args.key?(:use_topic_schema)
  @write_metadata = args[:write_metadata] if args.key?(:write_metadata)
end