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.
Implements
IMessage<TopologyConfig>, IEquatable<TopologyConfig>, IDeepCloneable<TopologyConfig>, IBufferMessage, IMessageNamespace
Google.Cloud.Dataflow.V1Beta3Assembly
Google.Cloud.Dataflow.V1Beta3.dll
Constructors
TopologyConfig()
public TopologyConfig()
TopologyConfig(TopologyConfig)
public TopologyConfig(TopologyConfig other)
Parameter | |
---|---|
Name | Description |
other | TopologyConfig |
Properties
Computations
public RepeatedField<ComputationTopology> Computations { get; }
The computations associated with a streaming Dataflow job.
Property Value | |
---|---|
Type | Description |
RepeatedField<ComputationTopology> |
DataDiskAssignments
public RepeatedField<DataDiskAssignment> DataDiskAssignments { get; }
The disks assigned to a streaming Dataflow job.
Property Value | |
---|---|
Type | Description |
RepeatedField<DataDiskAssignment> |
ForwardingKeyBits
public int ForwardingKeyBits { get; set; }
The size (in bits) of keys that will be assigned to source messages.
Property Value | |
---|---|
Type | Description |
Int32 |
PersistentStateVersion
public int PersistentStateVersion { get; set; }
Version number for persistent state.
Property Value | |
---|---|
Type | Description |
Int32 |
UserStageToComputationNameMap
public MapField<string, string> UserStageToComputationNameMap { get; }
Maps user stage names to stable computation names.
Property Value | |
---|---|
Type | Description |
MapField<String, String> |