generated/google/apis/dataflow_v1b3/representations.rb in google-api-client-0.10.0 vs generated/google/apis/dataflow_v1b3/representations.rb in google-api-client-0.10.1
- old
+ new
@@ -20,10 +20,202 @@
module Google
module Apis
module DataflowV1b3
+ class ParDoInstruction
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class MetricUpdate
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class CounterStructuredName
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class ApproximateProgress
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class WorkerMessageResponse
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class TemplateMetadata
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class WorkerMessage
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class JobMetrics
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class FloatingPointList
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class CounterUpdate
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class SourceMetadata
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class DistributionUpdate
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class SourceFork
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class WorkerHealthReportResponse
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class WorkItemStatus
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class ComponentSource
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class WorkItemServiceState
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class MetricStructuredName
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class SeqMapTaskOutputInfo
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class JobExecutionStageInfo
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class KeyRangeLocation
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class SourceGetMetadataRequest
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class SeqMapTask
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class NameAndKind
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class WorkerMessageCode
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class CustomSourceLocation
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class MapTask
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class FloatingPointMean
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class ReportWorkItemStatusResponse
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class InstructionOutput
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class CreateJobFromTemplateRequest
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
+ class IntegerMean
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
class ListJobsResponse
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -38,35 +230,41 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
+ class MountedDataDisk
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
class StreamingSideInputLocation
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class MountedDataDisk
+ class LaunchTemplateResponse
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class DynamicSourceSplit
+ class DerivedSource
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class Job
+ class DynamicSourceSplit
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class DerivedSource
+ class Job
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -86,35 +284,35 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class WriteInstruction
+ class CounterStructuredNameAndMetadata
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class CounterStructuredNameAndMetadata
+ class ConcatPosition
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class ConcatPosition
+ class WriteInstruction
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class AutoscalingSettings
+ class StreamingComputationRanges
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class StreamingComputationRanges
+ class AutoscalingSettings
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -194,10 +392,16 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
+ class ParameterMetadata
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
class MultiOutputInfo
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -302,17 +506,17 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class DataDiskAssignment
+ class StreamingStageLocation
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class StreamingStageLocation
+ class DataDiskAssignment
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -338,17 +542,17 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class TransformSummary
+ class StreamingComputationConfig
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class StreamingComputationConfig
+ class TransformSummary
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -356,10 +560,16 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
+ class LaunchTemplateParameters
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
class Sink
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -374,17 +584,17 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class StageSource
+ class InstructionInput
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class InstructionInput
+ class StageSource
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -398,17 +608,23 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
+ class GetDebugConfigRequest
+ class Representation < Google::Apis::Core::JsonRepresentation; end
+
+ include Google::Apis::Core::JsonObjectSupport
+ end
+
class LeaseWorkItemRequest
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class GetDebugConfigRequest
+ class GetTemplateResponse
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -416,17 +632,17 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class PipelineDescription
+ class StreamingConfigTask
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class StreamingConfigTask
+ class PipelineDescription
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -452,17 +668,17 @@
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class ListJobMessagesResponse
+ class CounterMetadata
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
- class CounterMetadata
+ class ListJobMessagesResponse
class Representation < Google::Apis::Core::JsonRepresentation; end
include Google::Apis::Core::JsonObjectSupport
end
@@ -513,220 +729,409 @@
include Google::Apis::Core::JsonObjectSupport
end
class ParDoInstruction
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ collection :multi_output_infos, as: 'multiOutputInfos', class: Google::Apis::DataflowV1b3::MultiOutputInfo, decorator: Google::Apis::DataflowV1b3::MultiOutputInfo::Representation
- include Google::Apis::Core::JsonObjectSupport
+ hash :user_fn, as: 'userFn'
+ property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation
+
+ property :num_outputs, as: 'numOutputs'
+ collection :side_inputs, as: 'sideInputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation
+
+ end
end
class MetricUpdate
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :set, as: 'set'
+ property :cumulative, as: 'cumulative'
+ property :internal, as: 'internal'
+ property :kind, as: 'kind'
+ property :scalar, as: 'scalar'
+ property :mean_count, as: 'meanCount'
+ property :mean_sum, as: 'meanSum'
+ property :update_time, as: 'updateTime'
+ property :name, as: 'name', class: Google::Apis::DataflowV1b3::MetricStructuredName, decorator: Google::Apis::DataflowV1b3::MetricStructuredName::Representation
- include Google::Apis::Core::JsonObjectSupport
+ end
end
class CounterStructuredName
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :component_step_name, as: 'componentStepName'
+ property :portion, as: 'portion'
+ property :original_step_name, as: 'originalStepName'
+ property :worker_id, as: 'workerId'
+ property :origin_namespace, as: 'originNamespace'
+ property :origin, as: 'origin'
+ property :name, as: 'name'
+ property :execution_step_name, as: 'executionStepName'
+ end
end
class ApproximateProgress
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :percent_complete, as: 'percentComplete'
+ property :remaining_time, as: 'remainingTime'
+ property :position, as: 'position', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation
- include Google::Apis::Core::JsonObjectSupport
+ end
end
class WorkerMessageResponse
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :worker_metrics_response, as: 'workerMetricsResponse', class: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse::Representation
- include Google::Apis::Core::JsonObjectSupport
+ property :worker_health_report_response, as: 'workerHealthReportResponse', class: Google::Apis::DataflowV1b3::WorkerHealthReportResponse, decorator: Google::Apis::DataflowV1b3::WorkerHealthReportResponse::Representation
+
+ end
end
+ class TemplateMetadata
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :bypass_temp_dir_validation, as: 'bypassTempDirValidation'
+ property :name, as: 'name'
+ collection :parameters, as: 'parameters', class: Google::Apis::DataflowV1b3::ParameterMetadata, decorator: Google::Apis::DataflowV1b3::ParameterMetadata::Representation
+
+ property :description, as: 'description'
+ end
+ end
+
class WorkerMessage
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :time, as: 'time'
+ property :worker_health_report, as: 'workerHealthReport', class: Google::Apis::DataflowV1b3::WorkerHealthReport, decorator: Google::Apis::DataflowV1b3::WorkerHealthReport::Representation
- include Google::Apis::Core::JsonObjectSupport
+ property :worker_message_code, as: 'workerMessageCode', class: Google::Apis::DataflowV1b3::WorkerMessageCode, decorator: Google::Apis::DataflowV1b3::WorkerMessageCode::Representation
+
+ property :worker_metrics, as: 'workerMetrics', class: Google::Apis::DataflowV1b3::ResourceUtilizationReport, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReport::Representation
+
+ hash :labels, as: 'labels'
+ end
end
class JobMetrics
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :metric_time, as: 'metricTime'
+ collection :metrics, as: 'metrics', class: Google::Apis::DataflowV1b3::MetricUpdate, decorator: Google::Apis::DataflowV1b3::MetricUpdate::Representation
- include Google::Apis::Core::JsonObjectSupport
+ end
end
class FloatingPointList
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ collection :elements, as: 'elements'
+ end
end
class CounterUpdate
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :floating_point_list, as: 'floatingPointList', class: Google::Apis::DataflowV1b3::FloatingPointList, decorator: Google::Apis::DataflowV1b3::FloatingPointList::Representation
- include Google::Apis::Core::JsonObjectSupport
+ property :integer, as: 'integer', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
+
+ property :integer_list, as: 'integerList', class: Google::Apis::DataflowV1b3::IntegerList, decorator: Google::Apis::DataflowV1b3::IntegerList::Representation
+
+ property :structured_name_and_metadata, as: 'structuredNameAndMetadata', class: Google::Apis::DataflowV1b3::CounterStructuredNameAndMetadata, decorator: Google::Apis::DataflowV1b3::CounterStructuredNameAndMetadata::Representation
+
+ property :floating_point, as: 'floatingPoint'
+ property :integer_mean, as: 'integerMean', class: Google::Apis::DataflowV1b3::IntegerMean, decorator: Google::Apis::DataflowV1b3::IntegerMean::Representation
+
+ property :cumulative, as: 'cumulative'
+ property :internal, as: 'internal'
+ property :floating_point_mean, as: 'floatingPointMean', class: Google::Apis::DataflowV1b3::FloatingPointMean, decorator: Google::Apis::DataflowV1b3::FloatingPointMean::Representation
+
+ property :boolean, as: 'boolean'
+ property :name_and_kind, as: 'nameAndKind', class: Google::Apis::DataflowV1b3::NameAndKind, decorator: Google::Apis::DataflowV1b3::NameAndKind::Representation
+
+ property :distribution, as: 'distribution', class: Google::Apis::DataflowV1b3::DistributionUpdate, decorator: Google::Apis::DataflowV1b3::DistributionUpdate::Representation
+
+ property :string_list, as: 'stringList', class: Google::Apis::DataflowV1b3::StringList, decorator: Google::Apis::DataflowV1b3::StringList::Representation
+
+ property :short_id, as: 'shortId'
+ end
end
class SourceMetadata
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :produces_sorted_keys, as: 'producesSortedKeys'
+ property :infinite, as: 'infinite'
+ property :estimated_size_bytes, as: 'estimatedSizeBytes'
+ end
end
class DistributionUpdate
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :min, as: 'min', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
- include Google::Apis::Core::JsonObjectSupport
+ property :sum_of_squares, as: 'sumOfSquares'
+ property :max, as: 'max', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
+
+ property :sum, as: 'sum', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
+
+ property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
+
+ end
end
class SourceFork
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :primary_source, as: 'primarySource', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation
- include Google::Apis::Core::JsonObjectSupport
+ property :residual, as: 'residual', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation
+
+ property :residual_source, as: 'residualSource', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation
+
+ property :primary, as: 'primary', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation
+
+ end
end
class WorkerHealthReportResponse
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :report_interval, as: 'reportInterval'
+ end
end
class WorkItemStatus
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ collection :counter_updates, as: 'counterUpdates', class: Google::Apis::DataflowV1b3::CounterUpdate, decorator: Google::Apis::DataflowV1b3::CounterUpdate::Representation
- include Google::Apis::Core::JsonObjectSupport
+ property :work_item_id, as: 'workItemId'
+ collection :metric_updates, as: 'metricUpdates', class: Google::Apis::DataflowV1b3::MetricUpdate, decorator: Google::Apis::DataflowV1b3::MetricUpdate::Representation
+
+ collection :errors, as: 'errors', class: Google::Apis::DataflowV1b3::Status, decorator: Google::Apis::DataflowV1b3::Status::Representation
+
+ property :dynamic_source_split, as: 'dynamicSourceSplit', class: Google::Apis::DataflowV1b3::DynamicSourceSplit, decorator: Google::Apis::DataflowV1b3::DynamicSourceSplit::Representation
+
+ property :source_operation_response, as: 'sourceOperationResponse', class: Google::Apis::DataflowV1b3::SourceOperationResponse, decorator: Google::Apis::DataflowV1b3::SourceOperationResponse::Representation
+
+ property :progress, as: 'progress', class: Google::Apis::DataflowV1b3::ApproximateProgress, decorator: Google::Apis::DataflowV1b3::ApproximateProgress::Representation
+
+ property :requested_lease_duration, as: 'requestedLeaseDuration'
+ property :report_index, as: 'reportIndex'
+ property :stop_position, as: 'stopPosition', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation
+
+ property :completed, as: 'completed'
+ property :reported_progress, as: 'reportedProgress', class: Google::Apis::DataflowV1b3::ApproximateReportedProgress, decorator: Google::Apis::DataflowV1b3::ApproximateReportedProgress::Representation
+
+ property :source_fork, as: 'sourceFork', class: Google::Apis::DataflowV1b3::SourceFork, decorator: Google::Apis::DataflowV1b3::SourceFork::Representation
+
+ end
end
class ComponentSource
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :original_transform_or_collection, as: 'originalTransformOrCollection'
+ property :name, as: 'name'
+ property :user_name, as: 'userName'
+ end
end
class WorkItemServiceState
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :report_status_interval, as: 'reportStatusInterval'
+ property :suggested_stop_position, as: 'suggestedStopPosition', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation
- include Google::Apis::Core::JsonObjectSupport
+ hash :harness_data, as: 'harnessData'
+ property :lease_expire_time, as: 'leaseExpireTime'
+ collection :metric_short_id, as: 'metricShortId', class: Google::Apis::DataflowV1b3::MetricShortId, decorator: Google::Apis::DataflowV1b3::MetricShortId::Representation
+
+ property :next_report_index, as: 'nextReportIndex'
+ property :suggested_stop_point, as: 'suggestedStopPoint', class: Google::Apis::DataflowV1b3::ApproximateProgress, decorator: Google::Apis::DataflowV1b3::ApproximateProgress::Representation
+
+ property :split_request, as: 'splitRequest', class: Google::Apis::DataflowV1b3::ApproximateSplitRequest, decorator: Google::Apis::DataflowV1b3::ApproximateSplitRequest::Representation
+
+ end
end
class MetricStructuredName
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :origin, as: 'origin'
+ property :name, as: 'name'
+ hash :context, as: 'context'
+ end
end
class SeqMapTaskOutputInfo
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :sink, as: 'sink', class: Google::Apis::DataflowV1b3::Sink, decorator: Google::Apis::DataflowV1b3::Sink::Representation
- include Google::Apis::Core::JsonObjectSupport
+ property :tag, as: 'tag'
+ end
end
class JobExecutionStageInfo
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ collection :step_name, as: 'stepName'
+ end
end
class KeyRangeLocation
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :delivery_endpoint, as: 'deliveryEndpoint'
+ property :start, as: 'start'
+ property :data_disk, as: 'dataDisk'
+ property :persistent_directory, as: 'persistentDirectory'
+ property :end, as: 'end'
+ end
end
class SourceGetMetadataRequest
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :source, as: 'source', class: Google::Apis::DataflowV1b3::Source, decorator: Google::Apis::DataflowV1b3::Source::Representation
- include Google::Apis::Core::JsonObjectSupport
+ end
end
class SeqMapTask
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :name, as: 'name'
+ collection :output_infos, as: 'outputInfos', class: Google::Apis::DataflowV1b3::SeqMapTaskOutputInfo, decorator: Google::Apis::DataflowV1b3::SeqMapTaskOutputInfo::Representation
- include Google::Apis::Core::JsonObjectSupport
+ collection :inputs, as: 'inputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation
+
+ property :stage_name, as: 'stageName'
+ property :system_name, as: 'systemName'
+ hash :user_fn, as: 'userFn'
+ end
end
class NameAndKind
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :name, as: 'name'
+ property :kind, as: 'kind'
+ end
end
class WorkerMessageCode
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ hash :parameters, as: 'parameters'
+ property :code, as: 'code'
+ end
end
class CustomSourceLocation
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :stateful, as: 'stateful'
+ end
end
class MapTask
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ collection :instructions, as: 'instructions', class: Google::Apis::DataflowV1b3::ParallelInstruction, decorator: Google::Apis::DataflowV1b3::ParallelInstruction::Representation
- include Google::Apis::Core::JsonObjectSupport
+ property :system_name, as: 'systemName'
+ property :stage_name, as: 'stageName'
+ end
end
class FloatingPointMean
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :sum, as: 'sum'
+ property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
- include Google::Apis::Core::JsonObjectSupport
+ end
end
class ReportWorkItemStatusResponse
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ collection :work_item_service_states, as: 'workItemServiceStates', class: Google::Apis::DataflowV1b3::WorkItemServiceState, decorator: Google::Apis::DataflowV1b3::WorkItemServiceState::Representation
- include Google::Apis::Core::JsonObjectSupport
+ end
end
class InstructionOutput
- class Representation < Google::Apis::Core::JsonRepresentation; end
-
- include Google::Apis::Core::JsonObjectSupport
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :system_name, as: 'systemName'
+ property :only_count_key_bytes, as: 'onlyCountKeyBytes'
+ property :only_count_value_bytes, as: 'onlyCountValueBytes'
+ hash :codec, as: 'codec'
+ property :name, as: 'name'
+ property :original_name, as: 'originalName'
+ end
end
class CreateJobFromTemplateRequest
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :gcs_path, as: 'gcsPath'
+ property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::RuntimeEnvironment, decorator: Google::Apis::DataflowV1b3::RuntimeEnvironment::Representation
- include Google::Apis::Core::JsonObjectSupport
+ hash :parameters, as: 'parameters'
+ property :job_name, as: 'jobName'
+ end
end
class IntegerMean
- class Representation < Google::Apis::Core::JsonRepresentation; end
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
- include Google::Apis::Core::JsonObjectSupport
+ property :sum, as: 'sum', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
+
+ end
end
class ListJobsResponse
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- collection :jobs, as: 'jobs', class: Google::Apis::DataflowV1b3::Job, decorator: Google::Apis::DataflowV1b3::Job::Representation
-
property :next_page_token, as: 'nextPageToken'
collection :failed_location, as: 'failedLocation', class: Google::Apis::DataflowV1b3::FailedLocation, decorator: Google::Apis::DataflowV1b3::FailedLocation::Representation
+ collection :jobs, as: 'jobs', class: Google::Apis::DataflowV1b3::Job, decorator: Google::Apis::DataflowV1b3::Job::Representation
+
end
end
class ComputationTopology
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- collection :key_ranges, as: 'keyRanges', class: Google::Apis::DataflowV1b3::KeyRangeLocation, decorator: Google::Apis::DataflowV1b3::KeyRangeLocation::Representation
-
property :user_stage_name, as: 'userStageName'
- collection :outputs, as: 'outputs', class: Google::Apis::DataflowV1b3::StreamLocation, decorator: Google::Apis::DataflowV1b3::StreamLocation::Representation
-
collection :state_families, as: 'stateFamilies', class: Google::Apis::DataflowV1b3::StateFamilyConfig, decorator: Google::Apis::DataflowV1b3::StateFamilyConfig::Representation
+ collection :outputs, as: 'outputs', class: Google::Apis::DataflowV1b3::StreamLocation, decorator: Google::Apis::DataflowV1b3::StreamLocation::Representation
+
property :system_stage_name, as: 'systemStageName'
- property :computation_id, as: 'computationId'
collection :inputs, as: 'inputs', class: Google::Apis::DataflowV1b3::StreamLocation, decorator: Google::Apis::DataflowV1b3::StreamLocation::Representation
+ property :computation_id, as: 'computationId'
+ collection :key_ranges, as: 'keyRanges', class: Google::Apis::DataflowV1b3::KeyRangeLocation, decorator: Google::Apis::DataflowV1b3::KeyRangeLocation::Representation
+
end
end
class RuntimeEnvironment
# @private
@@ -737,70 +1142,80 @@
property :temp_location, as: 'tempLocation'
property :bypass_temp_dir_validation, as: 'bypassTempDirValidation'
end
end
+ class MountedDataDisk
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :data_disk, as: 'dataDisk'
+ end
+ end
+
class StreamingSideInputLocation
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :tag, as: 'tag'
property :state_family, as: 'stateFamily'
+ property :tag, as: 'tag'
end
end
- class MountedDataDisk
+ class LaunchTemplateResponse
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :data_disk, as: 'dataDisk'
+ property :job, as: 'job', class: Google::Apis::DataflowV1b3::Job, decorator: Google::Apis::DataflowV1b3::Job::Representation
+
+ property :status, as: 'status', class: Google::Apis::DataflowV1b3::Status, decorator: Google::Apis::DataflowV1b3::Status::Representation
+
end
end
- class DynamicSourceSplit
+ class DerivedSource
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :residual, as: 'residual', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation
+ property :derivation_mode, as: 'derivationMode'
+ property :source, as: 'source', class: Google::Apis::DataflowV1b3::Source, decorator: Google::Apis::DataflowV1b3::Source::Representation
+ end
+ end
+
+ class DynamicSourceSplit
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
property :primary, as: 'primary', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation
+ property :residual, as: 'residual', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation
+
end
end
class Job
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :current_state, as: 'currentState'
- property :location, as: 'location'
- property :current_state_time, as: 'currentStateTime'
- hash :transform_name_mapping, as: 'transformNameMapping'
- property :create_time, as: 'createTime'
- property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::Environment, decorator: Google::Apis::DataflowV1b3::Environment::Representation
-
- hash :labels, as: 'labels'
- property :type, as: 'type'
- property :project_id, as: 'projectId'
property :pipeline_description, as: 'pipelineDescription', class: Google::Apis::DataflowV1b3::PipelineDescription, decorator: Google::Apis::DataflowV1b3::PipelineDescription::Representation
property :replace_job_id, as: 'replaceJobId'
property :requested_state, as: 'requestedState'
collection :temp_files, as: 'tempFiles'
property :client_request_id, as: 'clientRequestId'
property :name, as: 'name'
property :replaced_by_job_id, as: 'replacedByJobId'
collection :steps, as: 'steps', class: Google::Apis::DataflowV1b3::Step, decorator: Google::Apis::DataflowV1b3::Step::Representation
- property :id, as: 'id'
property :execution_info, as: 'executionInfo', class: Google::Apis::DataflowV1b3::JobExecutionInfo, decorator: Google::Apis::DataflowV1b3::JobExecutionInfo::Representation
- end
- end
+ property :id, as: 'id'
+ property :current_state, as: 'currentState'
+ property :location, as: 'location'
+ property :current_state_time, as: 'currentStateTime'
+ hash :transform_name_mapping, as: 'transformNameMapping'
+ hash :labels, as: 'labels'
+ property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::Environment, decorator: Google::Apis::DataflowV1b3::Environment::Representation
- class DerivedSource
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :derivation_mode, as: 'derivationMode'
- property :source, as: 'source', class: Google::Apis::DataflowV1b3::Source, decorator: Google::Apis::DataflowV1b3::Source::Representation
-
+ property :create_time, as: 'createTime'
+ property :type, as: 'type'
+ property :project_id, as: 'projectId'
end
end
class SourceOperationResponse
# @private
@@ -826,20 +1241,10 @@
hash :kind, as: 'kind'
property :tag, as: 'tag'
end
end
- class WriteInstruction
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation
-
- property :sink, as: 'sink', class: Google::Apis::DataflowV1b3::Sink, decorator: Google::Apis::DataflowV1b3::Sink::Representation
-
- end
- end
-
class CounterStructuredNameAndMetadata
# @private
class Representation < Google::Apis::Core::JsonRepresentation
property :name, as: 'name', class: Google::Apis::DataflowV1b3::CounterStructuredName, decorator: Google::Apis::DataflowV1b3::CounterStructuredName::Representation
@@ -849,47 +1254,57 @@
end
class ConcatPosition
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :index, as: 'index'
property :position, as: 'position', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation
+ property :index, as: 'index'
end
end
- class AutoscalingSettings
+ class WriteInstruction
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :max_num_workers, as: 'maxNumWorkers'
- property :algorithm, as: 'algorithm'
+ property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation
+
+ property :sink, as: 'sink', class: Google::Apis::DataflowV1b3::Sink, decorator: Google::Apis::DataflowV1b3::Sink::Representation
+
end
end
class StreamingComputationRanges
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :computation_id, as: 'computationId'
collection :range_assignments, as: 'rangeAssignments', class: Google::Apis::DataflowV1b3::KeyRangeDataDiskAssignment, decorator: Google::Apis::DataflowV1b3::KeyRangeDataDiskAssignment::Representation
+ property :computation_id, as: 'computationId'
end
end
- class ExecutionStageSummary
+ class AutoscalingSettings
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- collection :output_source, as: 'outputSource', class: Google::Apis::DataflowV1b3::StageSource, decorator: Google::Apis::DataflowV1b3::StageSource::Representation
+ property :max_num_workers, as: 'maxNumWorkers'
+ property :algorithm, as: 'algorithm'
+ end
+ end
- property :name, as: 'name'
+ class ExecutionStageSummary
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
collection :input_source, as: 'inputSource', class: Google::Apis::DataflowV1b3::StageSource, decorator: Google::Apis::DataflowV1b3::StageSource::Representation
property :id, as: 'id'
collection :component_transform, as: 'componentTransform', class: Google::Apis::DataflowV1b3::ComponentTransform, decorator: Google::Apis::DataflowV1b3::ComponentTransform::Representation
collection :component_source, as: 'componentSource', class: Google::Apis::DataflowV1b3::ComponentSource, decorator: Google::Apis::DataflowV1b3::ComponentSource::Representation
property :kind, as: 'kind'
+ collection :output_source, as: 'outputSource', class: Google::Apis::DataflowV1b3::StageSource, decorator: Google::Apis::DataflowV1b3::StageSource::Representation
+
+ property :name, as: 'name'
end
end
class SendWorkerMessagesRequest
# @private
@@ -918,21 +1333,21 @@
end
class Environment
# @private
class Representation < Google::Apis::Core::JsonRepresentation
+ property :service_account_email, as: 'serviceAccountEmail'
+ hash :user_agent, as: 'userAgent'
+ hash :sdk_pipeline_options, as: 'sdkPipelineOptions'
property :cluster_manager_api_service, as: 'clusterManagerApiService'
property :temp_storage_prefix, as: 'tempStoragePrefix'
collection :worker_pools, as: 'workerPools', class: Google::Apis::DataflowV1b3::WorkerPool, decorator: Google::Apis::DataflowV1b3::WorkerPool::Representation
property :dataset, as: 'dataset'
collection :experiments, as: 'experiments'
- hash :internal_experiments, as: 'internalExperiments'
hash :version, as: 'version'
- property :service_account_email, as: 'serviceAccountEmail'
- hash :user_agent, as: 'userAgent'
- hash :sdk_pipeline_options, as: 'sdkPipelineOptions'
+ hash :internal_experiments, as: 'internalExperiments'
end
end
class StreamingComputationTask
# @private
@@ -962,24 +1377,24 @@
end
class ComponentTransform
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :user_name, as: 'userName'
property :original_transform, as: 'originalTransform'
property :name, as: 'name'
+ property :user_name, as: 'userName'
end
end
class StreamingSetupTask
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :receive_work_port, as: 'receiveWorkPort'
property :streaming_computation_topology, as: 'streamingComputationTopology', class: Google::Apis::DataflowV1b3::TopologyConfig, decorator: Google::Apis::DataflowV1b3::TopologyConfig::Representation
property :worker_harness_port, as: 'workerHarnessPort'
property :drain, as: 'drain'
+ property :receive_work_port, as: 'receiveWorkPort'
end
end
class PubsubLocation
# @private
@@ -995,27 +1410,38 @@
end
class WorkerHealthReport
# @private
class Representation < Google::Apis::Core::JsonRepresentation
+ collection :pods, as: 'pods'
property :vm_startup_time, as: 'vmStartupTime'
property :vm_is_healthy, as: 'vmIsHealthy'
property :report_interval, as: 'reportInterval'
- collection :pods, as: 'pods'
end
end
class JobMessage
# @private
class Representation < Google::Apis::Core::JsonRepresentation
+ property :id, as: 'id'
property :message_text, as: 'messageText'
property :message_importance, as: 'messageImportance'
property :time, as: 'time'
- property :id, as: 'id'
end
end
+ class ParameterMetadata
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ collection :regexes, as: 'regexes'
+ property :label, as: 'label'
+ property :help_text, as: 'helpText'
+ property :is_optional, as: 'isOptional'
+ property :name, as: 'name'
+ end
+ end
+
class MultiOutputInfo
# @private
class Representation < Google::Apis::Core::JsonRepresentation
property :tag, as: 'tag'
end
@@ -1061,12 +1487,12 @@
property :task_group, as: 'taskGroup'
property :harness_command, as: 'harnessCommand'
property :log_dir, as: 'logDir'
property :dataflow_api_version, as: 'dataflowApiVersion'
collection :oauth_scopes, as: 'oauthScopes'
- property :log_upload_location, as: 'logUploadLocation'
property :streaming_worker_main_class, as: 'streamingWorkerMainClass'
+ property :log_upload_location, as: 'logUploadLocation'
property :workflow_file_name, as: 'workflowFileName'
property :temp_storage_prefix, as: 'tempStoragePrefix'
property :base_task_dir, as: 'baseTaskDir'
property :commandlines_file_name, as: 'commandlinesFileName'
property :language_hint, as: 'languageHint'
@@ -1082,17 +1508,17 @@
end
class Position
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :key, as: 'key'
- property :record_index, as: 'recordIndex'
- property :shuffle_position, as: 'shufflePosition'
- property :byte_offset, as: 'byteOffset'
property :concat_position, as: 'concatPosition', class: Google::Apis::DataflowV1b3::ConcatPosition, decorator: Google::Apis::DataflowV1b3::ConcatPosition::Representation
+ property :byte_offset, as: 'byteOffset'
property :end, as: 'end'
+ property :key, as: 'key'
+ property :record_index, as: 'recordIndex'
+ property :shuffle_position, as: 'shufflePosition'
end
end
class SplitInt64
# @private
@@ -1115,35 +1541,35 @@
end
class WorkerPool
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :network, as: 'network'
- property :default_package_set, as: 'defaultPackageSet'
- property :num_threads_per_worker, as: 'numThreadsPerWorker'
- property :num_workers, as: 'numWorkers'
- property :zone, as: 'zone'
- property :disk_source_image, as: 'diskSourceImage'
- collection :packages, as: 'packages', class: Google::Apis::DataflowV1b3::Package, decorator: Google::Apis::DataflowV1b3::Package::Representation
-
property :teardown_policy, as: 'teardownPolicy'
property :on_host_maintenance, as: 'onHostMaintenance'
hash :pool_args, as: 'poolArgs'
property :disk_size_gb, as: 'diskSizeGb'
property :worker_harness_container_image, as: 'workerHarnessContainerImage'
- property :disk_type, as: 'diskType'
property :machine_type, as: 'machineType'
+ property :disk_type, as: 'diskType'
property :kind, as: 'kind'
collection :data_disks, as: 'dataDisks', class: Google::Apis::DataflowV1b3::Disk, decorator: Google::Apis::DataflowV1b3::Disk::Representation
property :subnetwork, as: 'subnetwork'
property :ip_configuration, as: 'ipConfiguration'
property :autoscaling_settings, as: 'autoscalingSettings', class: Google::Apis::DataflowV1b3::AutoscalingSettings, decorator: Google::Apis::DataflowV1b3::AutoscalingSettings::Representation
property :taskrunner_settings, as: 'taskrunnerSettings', class: Google::Apis::DataflowV1b3::TaskRunnerSettings, decorator: Google::Apis::DataflowV1b3::TaskRunnerSettings::Representation
hash :metadata, as: 'metadata'
+ property :default_package_set, as: 'defaultPackageSet'
+ property :network, as: 'network'
+ property :num_threads_per_worker, as: 'numThreadsPerWorker'
+ property :zone, as: 'zone'
+ property :num_workers, as: 'numWorkers'
+ property :disk_source_image, as: 'diskSourceImage'
+ collection :packages, as: 'packages', class: Google::Apis::DataflowV1b3::Package, decorator: Google::Apis::DataflowV1b3::Package::Representation
+
end
end
class SourceOperationRequest
# @private
@@ -1156,33 +1582,33 @@
end
class WorkItem
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :lease_expire_time, as: 'leaseExpireTime'
- property :streaming_config_task, as: 'streamingConfigTask', class: Google::Apis::DataflowV1b3::StreamingConfigTask, decorator: Google::Apis::DataflowV1b3::StreamingConfigTask::Representation
-
property :initial_report_index, as: 'initialReportIndex'
- property :shell_task, as: 'shellTask', class: Google::Apis::DataflowV1b3::ShellTask, decorator: Google::Apis::DataflowV1b3::ShellTask::Representation
-
property :streaming_computation_task, as: 'streamingComputationTask', class: Google::Apis::DataflowV1b3::StreamingComputationTask, decorator: Google::Apis::DataflowV1b3::StreamingComputationTask::Representation
+ property :shell_task, as: 'shellTask', class: Google::Apis::DataflowV1b3::ShellTask, decorator: Google::Apis::DataflowV1b3::ShellTask::Representation
+
property :job_id, as: 'jobId'
property :id, as: 'id'
property :configuration, as: 'configuration'
property :map_task, as: 'mapTask', class: Google::Apis::DataflowV1b3::MapTask, decorator: Google::Apis::DataflowV1b3::MapTask::Representation
property :seq_map_task, as: 'seqMapTask', class: Google::Apis::DataflowV1b3::SeqMapTask, decorator: Google::Apis::DataflowV1b3::SeqMapTask::Representation
collection :packages, as: 'packages', class: Google::Apis::DataflowV1b3::Package, decorator: Google::Apis::DataflowV1b3::Package::Representation
property :project_id, as: 'projectId'
+ property :report_status_interval, as: 'reportStatusInterval'
property :streaming_setup_task, as: 'streamingSetupTask', class: Google::Apis::DataflowV1b3::StreamingSetupTask, decorator: Google::Apis::DataflowV1b3::StreamingSetupTask::Representation
- property :report_status_interval, as: 'reportStatusInterval'
property :source_operation_task, as: 'sourceOperationTask', class: Google::Apis::DataflowV1b3::SourceOperationRequest, decorator: Google::Apis::DataflowV1b3::SourceOperationRequest::Representation
+ property :lease_expire_time, as: 'leaseExpireTime'
+ property :streaming_config_task, as: 'streamingConfigTask', class: Google::Apis::DataflowV1b3::StreamingConfigTask, decorator: Google::Apis::DataflowV1b3::StreamingConfigTask::Representation
+
end
end
class ResourceUtilizationReport
# @private
@@ -1201,17 +1627,17 @@
end
class TopologyConfig
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- hash :user_stage_to_computation_name_map, as: 'userStageToComputationNameMap'
collection :computations, as: 'computations', class: Google::Apis::DataflowV1b3::ComputationTopology, decorator: Google::Apis::DataflowV1b3::ComputationTopology::Representation
collection :data_disk_assignments, as: 'dataDiskAssignments', class: Google::Apis::DataflowV1b3::DataDiskAssignment, decorator: Google::Apis::DataflowV1b3::DataDiskAssignment::Representation
property :persistent_state_version, as: 'persistentStateVersion'
property :forwarding_key_bits, as: 'forwardingKeyBits'
+ hash :user_stage_to_computation_name_map, as: 'userStageToComputationNameMap'
end
end
class SourceSplitOptions
# @private
@@ -1239,22 +1665,22 @@
property :shuffle_service_path, as: 'shuffleServicePath'
property :worker_id, as: 'workerId'
end
end
- class DataDiskAssignment
+ class StreamingStageLocation
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :vm_instance, as: 'vmInstance'
- collection :data_disks, as: 'dataDisks'
+ property :stream_id, as: 'streamId'
end
end
- class StreamingStageLocation
+ class DataDiskAssignment
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :stream_id, as: 'streamId'
+ property :vm_instance, as: 'vmInstance'
+ collection :data_disks, as: 'dataDisks'
end
end
class ApproximateSplitRequest
# @private
@@ -1266,13 +1692,13 @@
end
class Status
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- collection :details, as: 'details'
property :code, as: 'code'
property :message, as: 'message'
+ collection :details, as: 'details'
end
end
class StreamLocation
# @private
@@ -1294,39 +1720,49 @@
collection :worker_message_responses, as: 'workerMessageResponses', class: Google::Apis::DataflowV1b3::WorkerMessageResponse, decorator: Google::Apis::DataflowV1b3::WorkerMessageResponse::Representation
end
end
+ class StreamingComputationConfig
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :system_name, as: 'systemName'
+ property :stage_name, as: 'stageName'
+ collection :instructions, as: 'instructions', class: Google::Apis::DataflowV1b3::ParallelInstruction, decorator: Google::Apis::DataflowV1b3::ParallelInstruction::Representation
+
+ property :computation_id, as: 'computationId'
+ end
+ end
+
class TransformSummary
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- collection :output_collection_name, as: 'outputCollectionName'
+ property :id, as: 'id'
collection :display_data, as: 'displayData', class: Google::Apis::DataflowV1b3::DisplayData, decorator: Google::Apis::DataflowV1b3::DisplayData::Representation
+ collection :output_collection_name, as: 'outputCollectionName'
property :kind, as: 'kind'
collection :input_collection_name, as: 'inputCollectionName'
property :name, as: 'name'
- property :id, as: 'id'
end
end
- class StreamingComputationConfig
+ class LeaseWorkItemResponse
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :computation_id, as: 'computationId'
- property :system_name, as: 'systemName'
- property :stage_name, as: 'stageName'
- collection :instructions, as: 'instructions', class: Google::Apis::DataflowV1b3::ParallelInstruction, decorator: Google::Apis::DataflowV1b3::ParallelInstruction::Representation
+ collection :work_items, as: 'workItems', class: Google::Apis::DataflowV1b3::WorkItem, decorator: Google::Apis::DataflowV1b3::WorkItem::Representation
end
end
- class LeaseWorkItemResponse
+ class LaunchTemplateParameters
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- collection :work_items, as: 'workItems', class: Google::Apis::DataflowV1b3::WorkItem, decorator: Google::Apis::DataflowV1b3::WorkItem::Representation
+ property :job_name, as: 'jobName'
+ property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::RuntimeEnvironment, decorator: Google::Apis::DataflowV1b3::RuntimeEnvironment::Representation
+ hash :parameters, as: 'parameters'
end
end
class Sink
# @private
@@ -1345,36 +1781,36 @@
end
class PartialGroupByKeyInstruction
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- hash :value_combining_fn, as: 'valueCombiningFn'
hash :input_element_codec, as: 'inputElementCodec'
+ hash :value_combining_fn, as: 'valueCombiningFn'
property :original_combine_values_input_store_name, as: 'originalCombineValuesInputStoreName'
property :original_combine_values_step_name, as: 'originalCombineValuesStepName'
collection :side_inputs, as: 'sideInputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation
property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation
end
end
- class StageSource
+ class InstructionInput
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :name, as: 'name'
- property :original_user_transform_or_collection, as: 'originalUserTransformOrCollection'
- property :size_bytes, as: 'sizeBytes'
- property :user_name, as: 'userName'
+ property :producer_instruction_index, as: 'producerInstructionIndex'
+ property :output_num, as: 'outputNum'
end
end
- class InstructionInput
+ class StageSource
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :producer_instruction_index, as: 'producerInstructionIndex'
- property :output_num, as: 'outputNum'
+ property :original_transform_or_collection, as: 'originalTransformOrCollection'
+ property :name, as: 'name'
+ property :size_bytes, as: 'sizeBytes'
+ property :user_name, as: 'userName'
end
end
class StringList
# @private
@@ -1384,42 +1820,52 @@
end
class DisplayData
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :url, as: 'url'
- property :label, as: 'label'
- property :timestamp_value, as: 'timestampValue'
- property :bool_value, as: 'boolValue'
- property :java_class_value, as: 'javaClassValue'
- property :str_value, as: 'strValue'
- property :int64_value, as: 'int64Value'
property :duration_value, as: 'durationValue'
+ property :int64_value, as: 'int64Value'
property :namespace, as: 'namespace'
property :float_value, as: 'floatValue'
property :key, as: 'key'
property :short_str_value, as: 'shortStrValue'
+ property :label, as: 'label'
+ property :url, as: 'url'
+ property :timestamp_value, as: 'timestampValue'
+ property :bool_value, as: 'boolValue'
+ property :java_class_value, as: 'javaClassValue'
+ property :str_value, as: 'strValue'
end
end
+ class GetDebugConfigRequest
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ property :component_id, as: 'componentId'
+ property :worker_id, as: 'workerId'
+ end
+ end
+
class LeaseWorkItemRequest
# @private
class Representation < Google::Apis::Core::JsonRepresentation
property :current_worker_time, as: 'currentWorkerTime'
- collection :work_item_types, as: 'workItemTypes'
property :location, as: 'location'
+ collection :work_item_types, as: 'workItemTypes'
collection :worker_capabilities, as: 'workerCapabilities'
property :worker_id, as: 'workerId'
property :requested_lease_duration, as: 'requestedLeaseDuration'
end
end
- class GetDebugConfigRequest
+ class GetTemplateResponse
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :component_id, as: 'componentId'
- property :worker_id, as: 'workerId'
+ property :status, as: 'status', class: Google::Apis::DataflowV1b3::Status, decorator: Google::Apis::DataflowV1b3::Status::Representation
+
+ property :metadata, as: 'metadata', class: Google::Apis::DataflowV1b3::TemplateMetadata, decorator: Google::Apis::DataflowV1b3::TemplateMetadata::Representation
+
end
end
class ReportWorkItemStatusRequest
# @private
@@ -1430,10 +1876,19 @@
collection :work_item_statuses, as: 'workItemStatuses', class: Google::Apis::DataflowV1b3::WorkItemStatus, decorator: Google::Apis::DataflowV1b3::WorkItemStatus::Representation
end
end
+ class StreamingConfigTask
+ # @private
+ class Representation < Google::Apis::Core::JsonRepresentation
+ collection :streaming_computation_configs, as: 'streamingComputationConfigs', class: Google::Apis::DataflowV1b3::StreamingComputationConfig, decorator: Google::Apis::DataflowV1b3::StreamingComputationConfig::Representation
+
+ hash :user_step_to_state_family_name_map, as: 'userStepToStateFamilyNameMap'
+ end
+ end
+
class PipelineDescription
# @private
class Representation < Google::Apis::Core::JsonRepresentation
collection :original_pipeline_transform, as: 'originalPipelineTransform', class: Google::Apis::DataflowV1b3::TransformSummary, decorator: Google::Apis::DataflowV1b3::TransformSummary::Representation
@@ -1442,25 +1897,16 @@
collection :execution_pipeline_stage, as: 'executionPipelineStage', class: Google::Apis::DataflowV1b3::ExecutionStageSummary, decorator: Google::Apis::DataflowV1b3::ExecutionStageSummary::Representation
end
end
- class StreamingConfigTask
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- collection :streaming_computation_configs, as: 'streamingComputationConfigs', class: Google::Apis::DataflowV1b3::StreamingComputationConfig, decorator: Google::Apis::DataflowV1b3::StreamingComputationConfig::Representation
-
- hash :user_step_to_state_family_name_map, as: 'userStepToStateFamilyNameMap'
- end
- end
-
class Step
# @private
class Representation < Google::Apis::Core::JsonRepresentation
+ property :name, as: 'name'
property :kind, as: 'kind'
hash :properties, as: 'properties'
- property :name, as: 'name'
end
end
class JobExecutionInfo
# @private
@@ -1484,39 +1930,39 @@
property :disk_type, as: 'diskType'
property :mount_point, as: 'mountPoint'
end
end
- class ListJobMessagesResponse
+ class CounterMetadata
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :next_page_token, as: 'nextPageToken'
- collection :job_messages, as: 'jobMessages', class: Google::Apis::DataflowV1b3::JobMessage, decorator: Google::Apis::DataflowV1b3::JobMessage::Representation
-
+ property :standard_units, as: 'standardUnits'
+ property :other_units, as: 'otherUnits'
+ property :kind, as: 'kind'
+ property :description, as: 'description'
end
end
- class CounterMetadata
+ class ListJobMessagesResponse
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :kind, as: 'kind'
- property :description, as: 'description'
- property :standard_units, as: 'standardUnits'
- property :other_units, as: 'otherUnits'
+ collection :job_messages, as: 'jobMessages', class: Google::Apis::DataflowV1b3::JobMessage, decorator: Google::Apis::DataflowV1b3::JobMessage::Representation
+
+ property :next_page_token, as: 'nextPageToken'
end
end
class ApproximateReportedProgress
# @private
class Representation < Google::Apis::Core::JsonRepresentation
+ property :remaining_parallelism, as: 'remainingParallelism', class: Google::Apis::DataflowV1b3::ReportedParallelism, decorator: Google::Apis::DataflowV1b3::ReportedParallelism::Representation
+
property :position, as: 'position', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation
property :fraction_consumed, as: 'fractionConsumed'
property :consumed_parallelism, as: 'consumedParallelism', class: Google::Apis::DataflowV1b3::ReportedParallelism, decorator: Google::Apis::DataflowV1b3::ReportedParallelism::Representation
- property :remaining_parallelism, as: 'remainingParallelism', class: Google::Apis::DataflowV1b3::ReportedParallelism, decorator: Google::Apis::DataflowV1b3::ReportedParallelism::Representation
-
end
end
class StateFamilyConfig
# @private
@@ -1541,416 +1987,52 @@
end
class SourceSplitResponse
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- collection :shards, as: 'shards', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation
-
property :outcome, as: 'outcome'
collection :bundles, as: 'bundles', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation
+ collection :shards, as: 'shards', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation
+
end
end
class ParallelInstruction
# @private
class Representation < Google::Apis::Core::JsonRepresentation
collection :outputs, as: 'outputs', class: Google::Apis::DataflowV1b3::InstructionOutput, decorator: Google::Apis::DataflowV1b3::InstructionOutput::Representation
property :name, as: 'name'
- property :read, as: 'read', class: Google::Apis::DataflowV1b3::ReadInstruction, decorator: Google::Apis::DataflowV1b3::ReadInstruction::Representation
-
property :par_do, as: 'parDo', class: Google::Apis::DataflowV1b3::ParDoInstruction, decorator: Google::Apis::DataflowV1b3::ParDoInstruction::Representation
- property :flatten, as: 'flatten', class: Google::Apis::DataflowV1b3::FlattenInstruction, decorator: Google::Apis::DataflowV1b3::FlattenInstruction::Representation
+ property :read, as: 'read', class: Google::Apis::DataflowV1b3::ReadInstruction, decorator: Google::Apis::DataflowV1b3::ReadInstruction::Representation
property :original_name, as: 'originalName'
- property :system_name, as: 'systemName'
+ property :flatten, as: 'flatten', class: Google::Apis::DataflowV1b3::FlattenInstruction, decorator: Google::Apis::DataflowV1b3::FlattenInstruction::Representation
+
property :write, as: 'write', class: Google::Apis::DataflowV1b3::WriteInstruction, decorator: Google::Apis::DataflowV1b3::WriteInstruction::Representation
+ property :system_name, as: 'systemName'
property :partial_group_by_key, as: 'partialGroupByKey', class: Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction, decorator: Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction::Representation
end
end
class Package
# @private
class Representation < Google::Apis::Core::JsonRepresentation
- property :location, as: 'location'
property :name, as: 'name'
+ property :location, as: 'location'
end
end
class KeyRangeDataDiskAssignment
# @private
class Representation < Google::Apis::Core::JsonRepresentation
property :start, as: 'start'
property :data_disk, as: 'dataDisk'
property :end, as: 'end'
- end
- end
-
- class ParDoInstruction
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- collection :multi_output_infos, as: 'multiOutputInfos', class: Google::Apis::DataflowV1b3::MultiOutputInfo, decorator: Google::Apis::DataflowV1b3::MultiOutputInfo::Representation
-
- hash :user_fn, as: 'userFn'
- property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation
-
- property :num_outputs, as: 'numOutputs'
- collection :side_inputs, as: 'sideInputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation
-
- end
- end
-
- class MetricUpdate
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :internal, as: 'internal'
- property :cumulative, as: 'cumulative'
- property :kind, as: 'kind'
- property :scalar, as: 'scalar'
- property :mean_count, as: 'meanCount'
- property :mean_sum, as: 'meanSum'
- property :update_time, as: 'updateTime'
- property :name, as: 'name', class: Google::Apis::DataflowV1b3::MetricStructuredName, decorator: Google::Apis::DataflowV1b3::MetricStructuredName::Representation
-
- property :set, as: 'set'
- end
- end
-
- class CounterStructuredName
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :component_step_name, as: 'componentStepName'
- property :portion, as: 'portion'
- property :original_step_name, as: 'originalStepName'
- property :worker_id, as: 'workerId'
- property :origin_namespace, as: 'originNamespace'
- property :origin, as: 'origin'
- property :name, as: 'name'
- property :execution_step_name, as: 'executionStepName'
- end
- end
-
- class ApproximateProgress
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :position, as: 'position', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation
-
- property :percent_complete, as: 'percentComplete'
- property :remaining_time, as: 'remainingTime'
- end
- end
-
- class WorkerMessageResponse
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :worker_metrics_response, as: 'workerMetricsResponse', class: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse::Representation
-
- property :worker_health_report_response, as: 'workerHealthReportResponse', class: Google::Apis::DataflowV1b3::WorkerHealthReportResponse, decorator: Google::Apis::DataflowV1b3::WorkerHealthReportResponse::Representation
-
- end
- end
-
- class WorkerMessage
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :time, as: 'time'
- property :worker_health_report, as: 'workerHealthReport', class: Google::Apis::DataflowV1b3::WorkerHealthReport, decorator: Google::Apis::DataflowV1b3::WorkerHealthReport::Representation
-
- property :worker_message_code, as: 'workerMessageCode', class: Google::Apis::DataflowV1b3::WorkerMessageCode, decorator: Google::Apis::DataflowV1b3::WorkerMessageCode::Representation
-
- property :worker_metrics, as: 'workerMetrics', class: Google::Apis::DataflowV1b3::ResourceUtilizationReport, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReport::Representation
-
- hash :labels, as: 'labels'
- end
- end
-
- class JobMetrics
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :metric_time, as: 'metricTime'
- collection :metrics, as: 'metrics', class: Google::Apis::DataflowV1b3::MetricUpdate, decorator: Google::Apis::DataflowV1b3::MetricUpdate::Representation
-
- end
- end
-
- class FloatingPointList
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- collection :elements, as: 'elements'
- end
- end
-
- class CounterUpdate
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :floating_point_list, as: 'floatingPointList', class: Google::Apis::DataflowV1b3::FloatingPointList, decorator: Google::Apis::DataflowV1b3::FloatingPointList::Representation
-
- property :integer, as: 'integer', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
-
- property :integer_list, as: 'integerList', class: Google::Apis::DataflowV1b3::IntegerList, decorator: Google::Apis::DataflowV1b3::IntegerList::Representation
-
- property :structured_name_and_metadata, as: 'structuredNameAndMetadata', class: Google::Apis::DataflowV1b3::CounterStructuredNameAndMetadata, decorator: Google::Apis::DataflowV1b3::CounterStructuredNameAndMetadata::Representation
-
- property :integer_mean, as: 'integerMean', class: Google::Apis::DataflowV1b3::IntegerMean, decorator: Google::Apis::DataflowV1b3::IntegerMean::Representation
-
- property :floating_point, as: 'floatingPoint'
- property :cumulative, as: 'cumulative'
- property :internal, as: 'internal'
- property :floating_point_mean, as: 'floatingPointMean', class: Google::Apis::DataflowV1b3::FloatingPointMean, decorator: Google::Apis::DataflowV1b3::FloatingPointMean::Representation
-
- property :boolean, as: 'boolean'
- property :name_and_kind, as: 'nameAndKind', class: Google::Apis::DataflowV1b3::NameAndKind, decorator: Google::Apis::DataflowV1b3::NameAndKind::Representation
-
- property :string_list, as: 'stringList', class: Google::Apis::DataflowV1b3::StringList, decorator: Google::Apis::DataflowV1b3::StringList::Representation
-
- property :distribution, as: 'distribution', class: Google::Apis::DataflowV1b3::DistributionUpdate, decorator: Google::Apis::DataflowV1b3::DistributionUpdate::Representation
-
- property :short_id, as: 'shortId'
- end
- end
-
- class SourceMetadata
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :produces_sorted_keys, as: 'producesSortedKeys'
- property :infinite, as: 'infinite'
- property :estimated_size_bytes, as: 'estimatedSizeBytes'
- end
- end
-
- class DistributionUpdate
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
-
- property :min, as: 'min', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
-
- property :sum_of_squares, as: 'sumOfSquares'
- property :max, as: 'max', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
-
- property :sum, as: 'sum', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
-
- end
- end
-
- class SourceFork
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :residual, as: 'residual', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation
-
- property :residual_source, as: 'residualSource', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation
-
- property :primary, as: 'primary', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation
-
- property :primary_source, as: 'primarySource', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation
-
- end
- end
-
- class WorkerHealthReportResponse
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :report_interval, as: 'reportInterval'
- end
- end
-
- class WorkItemStatus
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- collection :counter_updates, as: 'counterUpdates', class: Google::Apis::DataflowV1b3::CounterUpdate, decorator: Google::Apis::DataflowV1b3::CounterUpdate::Representation
-
- property :work_item_id, as: 'workItemId'
- collection :metric_updates, as: 'metricUpdates', class: Google::Apis::DataflowV1b3::MetricUpdate, decorator: Google::Apis::DataflowV1b3::MetricUpdate::Representation
-
- collection :errors, as: 'errors', class: Google::Apis::DataflowV1b3::Status, decorator: Google::Apis::DataflowV1b3::Status::Representation
-
- property :dynamic_source_split, as: 'dynamicSourceSplit', class: Google::Apis::DataflowV1b3::DynamicSourceSplit, decorator: Google::Apis::DataflowV1b3::DynamicSourceSplit::Representation
-
- property :source_operation_response, as: 'sourceOperationResponse', class: Google::Apis::DataflowV1b3::SourceOperationResponse, decorator: Google::Apis::DataflowV1b3::SourceOperationResponse::Representation
-
- property :progress, as: 'progress', class: Google::Apis::DataflowV1b3::ApproximateProgress, decorator: Google::Apis::DataflowV1b3::ApproximateProgress::Representation
-
- property :requested_lease_duration, as: 'requestedLeaseDuration'
- property :report_index, as: 'reportIndex'
- property :stop_position, as: 'stopPosition', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation
-
- property :completed, as: 'completed'
- property :reported_progress, as: 'reportedProgress', class: Google::Apis::DataflowV1b3::ApproximateReportedProgress, decorator: Google::Apis::DataflowV1b3::ApproximateReportedProgress::Representation
-
- property :source_fork, as: 'sourceFork', class: Google::Apis::DataflowV1b3::SourceFork, decorator: Google::Apis::DataflowV1b3::SourceFork::Representation
-
- end
- end
-
- class ComponentSource
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :user_name, as: 'userName'
- property :original_transform_or_collection, as: 'originalTransformOrCollection'
- property :name, as: 'name'
- end
- end
-
- class WorkItemServiceState
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :split_request, as: 'splitRequest', class: Google::Apis::DataflowV1b3::ApproximateSplitRequest, decorator: Google::Apis::DataflowV1b3::ApproximateSplitRequest::Representation
-
- property :report_status_interval, as: 'reportStatusInterval'
- property :suggested_stop_position, as: 'suggestedStopPosition', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation
-
- hash :harness_data, as: 'harnessData'
- property :lease_expire_time, as: 'leaseExpireTime'
- collection :metric_short_id, as: 'metricShortId', class: Google::Apis::DataflowV1b3::MetricShortId, decorator: Google::Apis::DataflowV1b3::MetricShortId::Representation
-
- property :next_report_index, as: 'nextReportIndex'
- property :suggested_stop_point, as: 'suggestedStopPoint', class: Google::Apis::DataflowV1b3::ApproximateProgress, decorator: Google::Apis::DataflowV1b3::ApproximateProgress::Representation
-
- end
- end
-
- class MetricStructuredName
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- hash :context, as: 'context'
- property :origin, as: 'origin'
- property :name, as: 'name'
- end
- end
-
- class SeqMapTaskOutputInfo
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :sink, as: 'sink', class: Google::Apis::DataflowV1b3::Sink, decorator: Google::Apis::DataflowV1b3::Sink::Representation
-
- property :tag, as: 'tag'
- end
- end
-
- class JobExecutionStageInfo
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- collection :step_name, as: 'stepName'
- end
- end
-
- class KeyRangeLocation
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :persistent_directory, as: 'persistentDirectory'
- property :end, as: 'end'
- property :delivery_endpoint, as: 'deliveryEndpoint'
- property :start, as: 'start'
- property :data_disk, as: 'dataDisk'
- end
- end
-
- class SourceGetMetadataRequest
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :source, as: 'source', class: Google::Apis::DataflowV1b3::Source, decorator: Google::Apis::DataflowV1b3::Source::Representation
-
- end
- end
-
- class SeqMapTask
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :name, as: 'name'
- collection :output_infos, as: 'outputInfos', class: Google::Apis::DataflowV1b3::SeqMapTaskOutputInfo, decorator: Google::Apis::DataflowV1b3::SeqMapTaskOutputInfo::Representation
-
- collection :inputs, as: 'inputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation
-
- property :system_name, as: 'systemName'
- property :stage_name, as: 'stageName'
- hash :user_fn, as: 'userFn'
- end
- end
-
- class NameAndKind
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :name, as: 'name'
- property :kind, as: 'kind'
- end
- end
-
- class WorkerMessageCode
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- hash :parameters, as: 'parameters'
- property :code, as: 'code'
- end
- end
-
- class CustomSourceLocation
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :stateful, as: 'stateful'
- end
- end
-
- class MapTask
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :system_name, as: 'systemName'
- property :stage_name, as: 'stageName'
- collection :instructions, as: 'instructions', class: Google::Apis::DataflowV1b3::ParallelInstruction, decorator: Google::Apis::DataflowV1b3::ParallelInstruction::Representation
-
- end
- end
-
- class FloatingPointMean
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :sum, as: 'sum'
- property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
-
- end
- end
-
- class ReportWorkItemStatusResponse
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- collection :work_item_service_states, as: 'workItemServiceStates', class: Google::Apis::DataflowV1b3::WorkItemServiceState, decorator: Google::Apis::DataflowV1b3::WorkItemServiceState::Representation
-
- end
- end
-
- class InstructionOutput
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :name, as: 'name'
- property :original_name, as: 'originalName'
- property :system_name, as: 'systemName'
- property :only_count_key_bytes, as: 'onlyCountKeyBytes'
- property :only_count_value_bytes, as: 'onlyCountValueBytes'
- hash :codec, as: 'codec'
- end
- end
-
- class CreateJobFromTemplateRequest
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- hash :parameters, as: 'parameters'
- property :job_name, as: 'jobName'
- property :gcs_path, as: 'gcsPath'
- property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::RuntimeEnvironment, decorator: Google::Apis::DataflowV1b3::RuntimeEnvironment::Representation
-
- end
- end
-
- class IntegerMean
- # @private
- class Representation < Google::Apis::Core::JsonRepresentation
- property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
-
- property :sum, as: 'sum', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation
-
end
end
end
end
end