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