Class: Google::Cloud::Dataflow::V1beta3::TopologyConfig

Inherits:
Object
  • Object
show all
Extended by:
Protobuf::MessageExts::ClassMethods
Includes:
Protobuf::MessageExts
Defined in:
proto_docs/google/dataflow/v1beta3/streaming.rb

Overview

Global topology of the streaming Dataflow job, including all computations and their sharded locations.

Defined Under Namespace

Classes: UserStageToComputationNameMapEntry

Instance Attribute Summary collapse

Instance Attribute Details

#computations ⇒ ::Array<::Google::Cloud::Dataflow::V1beta3::ComputationTopology>

Returns The computations associated with a streaming Dataflow job.

Returns:



41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 41

class TopologyConfig
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods

  # @!attribute [rw] key
  #   @return [::String]
  # @!attribute [rw] value
  #   @return [::String]
  class UserStageToComputationNameMapEntry
    include ::Google::Protobuf::MessageExts
    extend ::Google::Protobuf::MessageExts::ClassMethods
  end
end

#data_disk_assignments ⇒ ::Array<::Google::Cloud::Dataflow::V1beta3::DataDiskAssignment>

Returns The disks assigned to a streaming Dataflow job.

Returns:



41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 41

class TopologyConfig
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods

  # @!attribute [rw] key
  #   @return [::String]
  # @!attribute [rw] value
  #   @return [::String]
  class UserStageToComputationNameMapEntry
    include ::Google::Protobuf::MessageExts
    extend ::Google::Protobuf::MessageExts::ClassMethods
  end
end

#forwarding_key_bits ⇒ ::Integer

Returns The size (in bits) of keys that will be assigned to source messages.

Returns:

  • (::Integer) —

    The size (in bits) of keys that will be assigned to source messages.



41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 41

class TopologyConfig
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods

  # @!attribute [rw] key
  #   @return [::String]
  # @!attribute [rw] value
  #   @return [::String]
  class UserStageToComputationNameMapEntry
    include ::Google::Protobuf::MessageExts
    extend ::Google::Protobuf::MessageExts::ClassMethods
  end
end

#persistent_state_version ⇒ ::Integer

Returns Version number for persistent state.

Returns:

  • (::Integer) —

    Version number for persistent state.



41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 41

class TopologyConfig
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods

  # @!attribute [rw] key
  #   @return [::String]
  # @!attribute [rw] value
  #   @return [::String]
  class UserStageToComputationNameMapEntry
    include ::Google::Protobuf::MessageExts
    extend ::Google::Protobuf::MessageExts::ClassMethods
  end
end

#user_stage_to_computation_name_map ⇒ ::Google::Protobuf::Map{::String => ::String}

Returns Maps user stage names to stable computation names.

Returns:

  • (::Google::Protobuf::Map{::String => ::String}) —

    Maps user stage names to stable computation names.



41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'proto_docs/google/dataflow/v1beta3/streaming.rb', line 41

class TopologyConfig
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods

  # @!attribute [rw] key
  #   @return [::String]
  # @!attribute [rw] value
  #   @return [::String]
  class UserStageToComputationNameMapEntry
    include ::Google::Protobuf::MessageExts
    extend ::Google::Protobuf::MessageExts::ClassMethods
  end
end