Class: Google::Apis::DataflowV1b3::SourceSplitResponse

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

Overview

The response to a SourceSplitRequest.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ SourceSplitResponse

Returns a new instance of SourceSplitResponse.



4915
4916
4917
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4915

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

Instance Attribute Details

#bundlesArray<Google::Apis::DataflowV1b3::DerivedSource>

If outcome is SPLITTING_HAPPENED, then this is a list of bundles into which the source was split. Otherwise this field is ignored. This list can be empty, which means the source represents an empty input. Corresponds to the JSON property bundles



4899
4900
4901
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4899

def bundles
  @bundles
end

#outcomeString

Indicates whether splitting happened and produced a list of bundles. If this is USE_CURRENT_SOURCE_AS_IS, the current source should be processed "as is" without splitting. "bundles" is ignored in this case. If this is SPLITTING_HAPPENED, then "bundles" contains a list of bundles into which the source was split. Corresponds to the JSON property outcome

Returns:

  • (String)


4908
4909
4910
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4908

def outcome
  @outcome
end

#shardsArray<Google::Apis::DataflowV1b3::SourceSplitShard>

DEPRECATED in favor of bundles. Corresponds to the JSON property shards



4913
4914
4915
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4913

def shards
  @shards
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



4920
4921
4922
4923
4924
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4920

def update!(**args)
  @bundles = args[:bundles] if args.key?(:bundles)
  @outcome = args[:outcome] if args.key?(:outcome)
  @shards = args[:shards] if args.key?(:shards)
end