Class TopologyConfig

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

Attributes
NameDescription
Sequence[google.cloud.dataflow_v1beta3.types.ComputationTopology]computations
The computations associated with a streaming Dataflow job.
Sequence[google.cloud.dataflow_v1beta3.types.DataDiskAssignment]data_disk_assignments
The disks assigned to a streaming Dataflow job.
Sequence[google.cloud.dataflow_v1beta3.types.TopologyConfig.UserStageToComputationNameMapEntry]user_stage_to_computation_name_map
Maps user stage names to stable computation names.
intforwarding_key_bits
The size (in bits) of keys that will be assigned to source messages.
intpersistent_state_version
Version number for persistent state.

Inheritance

builtins.object > proto.message.Message > TopologyConfig

Classes

UserStageToComputationNameMapEntry

UserStageToComputationNameMapEntry(
    mapping=None, *, ignore_unknown_fields=False, **kwargs
)

API documentation for dataflow_v1beta3.types.TopologyConfig.UserStageToComputationNameMapEntry class.