lib/google/apis/datastream_v1/classes.rb in google-apis-datastream_v1-0.34.0 vs lib/google/apis/datastream_v1/classes.rb in google-apis-datastream_v1-0.35.0

- old
+ new

@@ -20,10 +20,24 @@ module Google module Apis module DatastreamV1 + # AppendOnly mode defines that all changes to a table will be written to the + # destination table. + class AppendOnly + include Google::Apis::Core::Hashable + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + end + end + # AVRO file format configuration. class AvroFileFormat include Google::Apis::Core::Hashable def initialize(**args) @@ -131,18 +145,30 @@ # BigQuery destination configuration class BigQueryDestinationConfig include Google::Apis::Core::Hashable + # AppendOnly mode defines that all changes to a table will be written to the + # destination table. + # Corresponds to the JSON property `appendOnly` + # @return [Google::Apis::DatastreamV1::AppendOnly] + attr_accessor :append_only + # The guaranteed data freshness (in seconds) when querying tables created by the # stream. Editing this field will only affect new tables created in the future, # but existing tables will not be impacted. Lower values mean that queries will # return fresher data, but may result in higher cost. # Corresponds to the JSON property `dataFreshness` # @return [String] attr_accessor :data_freshness + # Merge mode defines that all changes to a table will be merged at the + # destination table. + # Corresponds to the JSON property `merge` + # @return [Google::Apis::DatastreamV1::Merge] + attr_accessor :merge + # A single target dataset to which all data will be streamed. # Corresponds to the JSON property `singleTargetDataset` # @return [Google::Apis::DatastreamV1::SingleTargetDataset] attr_accessor :single_target_dataset @@ -156,11 +182,13 @@ update!(**args) end # Update properties of this object def update!(**args) + @append_only = args[:append_only] if args.key?(:append_only) @data_freshness = args[:data_freshness] if args.key?(:data_freshness) + @merge = args[:merge] if args.key?(:merge) @single_target_dataset = args[:single_target_dataset] if args.key?(:single_target_dataset) @source_hierarchy_datasets = args[:source_hierarchy_datasets] if args.key?(:source_hierarchy_datasets) end end @@ -983,9 +1011,23 @@ end # Update properties of this object def update!(**args) @source_object_identifier = args[:source_object_identifier] if args.key?(:source_object_identifier) + end + end + + # Merge mode defines that all changes to a table will be merged at the + # destination table. + class Merge + include Google::Apis::Core::Hashable + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) end end # CDC strategy to start replicating from the most recent position in the source. class MostRecentStartPosition