Class TopologyConfig (1.0.0-beta03)

public sealed class TopologyConfig : IMessage<TopologyConfig>, IEquatable<TopologyConfig>, IDeepCloneable<TopologyConfig>, IBufferMessage, IMessage

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

Inheritance

Object > TopologyConfig

Namespace

Google.Cloud.Dataflow.V1Beta3

Assembly

Google.Cloud.Dataflow.V1Beta3.dll

Constructors

TopologyConfig()

public TopologyConfig()

TopologyConfig(TopologyConfig)

public TopologyConfig(TopologyConfig other)
Parameter
NameDescription
otherTopologyConfig

Properties

Computations

public RepeatedField<ComputationTopology> Computations { get; }

The computations associated with a streaming Dataflow job.

Property Value
TypeDescription
RepeatedField<ComputationTopology>

DataDiskAssignments

public RepeatedField<DataDiskAssignment> DataDiskAssignments { get; }

The disks assigned to a streaming Dataflow job.

Property Value
TypeDescription
RepeatedField<DataDiskAssignment>

ForwardingKeyBits

public int ForwardingKeyBits { get; set; }

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

Property Value
TypeDescription
Int32

PersistentStateVersion

public int PersistentStateVersion { get; set; }

Version number for persistent state.

Property Value
TypeDescription
Int32

UserStageToComputationNameMap

public MapField<string, string> UserStageToComputationNameMap { get; }

Maps user stage names to stable computation names.

Property Value
TypeDescription
MapField<String, String>