Interface TopologyConfigOrBuilder

Stay organized with collections Save and categorize content based on your preferences.
public interface TopologyConfigOrBuilder extends MessageOrBuilder

Implements

MessageOrBuilder

Methods

containsUserStageToComputationNameMap(String key)

public abstract boolean containsUserStageToComputationNameMap(String key)

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Parameter
NameDescription
keyString
Returns
TypeDescription
boolean

getComputations(int index)

public abstract ComputationTopology getComputations(int index)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter
NameDescription
indexint
Returns
TypeDescription
ComputationTopology

getComputationsCount()

public abstract int getComputationsCount()

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Returns
TypeDescription
int

getComputationsList()

public abstract List<ComputationTopology> getComputationsList()

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Returns
TypeDescription
List<ComputationTopology>

getComputationsOrBuilder(int index)

public abstract ComputationTopologyOrBuilder getComputationsOrBuilder(int index)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter
NameDescription
indexint
Returns
TypeDescription
ComputationTopologyOrBuilder

getComputationsOrBuilderList()

public abstract List<? extends ComputationTopologyOrBuilder> getComputationsOrBuilderList()

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Returns
TypeDescription
List<? extends com.google.dataflow.v1beta3.ComputationTopologyOrBuilder>

getDataDiskAssignments(int index)

public abstract DataDiskAssignment getDataDiskAssignments(int index)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter
NameDescription
indexint
Returns
TypeDescription
DataDiskAssignment

getDataDiskAssignmentsCount()

public abstract int getDataDiskAssignmentsCount()

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Returns
TypeDescription
int

getDataDiskAssignmentsList()

public abstract List<DataDiskAssignment> getDataDiskAssignmentsList()

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Returns
TypeDescription
List<DataDiskAssignment>

getDataDiskAssignmentsOrBuilder(int index)

public abstract DataDiskAssignmentOrBuilder getDataDiskAssignmentsOrBuilder(int index)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter
NameDescription
indexint
Returns
TypeDescription
DataDiskAssignmentOrBuilder

getDataDiskAssignmentsOrBuilderList()

public abstract List<? extends DataDiskAssignmentOrBuilder> getDataDiskAssignmentsOrBuilderList()

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Returns
TypeDescription
List<? extends com.google.dataflow.v1beta3.DataDiskAssignmentOrBuilder>

getForwardingKeyBits()

public abstract int getForwardingKeyBits()

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

int32 forwarding_key_bits = 4;

Returns
TypeDescription
int

The forwardingKeyBits.

getPersistentStateVersion()

public abstract int getPersistentStateVersion()

Version number for persistent state.

int32 persistent_state_version = 5;

Returns
TypeDescription
int

The persistentStateVersion.

getUserStageToComputationNameMap()

public abstract Map<String,String> getUserStageToComputationNameMap()
Returns
TypeDescription
Map<String,String>

getUserStageToComputationNameMapCount()

public abstract int getUserStageToComputationNameMapCount()

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Returns
TypeDescription
int

getUserStageToComputationNameMapMap()

public abstract Map<String,String> getUserStageToComputationNameMapMap()

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Returns
TypeDescription
Map<String,String>

getUserStageToComputationNameMapOrDefault(String key, String defaultValue)

public abstract String getUserStageToComputationNameMapOrDefault(String key, String defaultValue)

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Parameters
NameDescription
keyString
defaultValueString
Returns
TypeDescription
String

getUserStageToComputationNameMapOrThrow(String key)

public abstract String getUserStageToComputationNameMapOrThrow(String key)

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Parameter
NameDescription
keyString
Returns
TypeDescription
String