- 0.82.0 (latest)
 - 0.80.0
 - 0.79.0
 - 0.78.0
 - 0.77.0
 - 0.76.0
 - 0.74.0
 - 0.72.0
 - 0.71.0
 - 0.68.0
 - 0.67.0
 - 0.66.0
 - 0.64.0
 - 0.63.0
 - 0.62.0
 - 0.61.0
 - 0.60.0
 - 0.59.0
 - 0.58.0
 - 0.57.0
 - 0.56.0
 - 0.55.0
 - 0.53.0
 - 0.52.0
 - 0.51.0
 - 0.50.0
 - 0.49.0
 - 0.48.0
 - 0.47.0
 - 0.46.0
 - 0.45.0
 - 0.44.0
 - 0.43.0
 - 0.41.0
 - 0.40.0
 - 0.39.0
 - 0.38.0
 - 0.37.0
 - 0.36.0
 - 0.35.0
 - 0.34.0
 - 0.33.0
 - 0.32.0
 - 0.31.0
 - 0.28.0
 - 0.27.0
 - 0.26.0
 - 0.25.0
 - 0.24.0
 - 0.23.0
 - 0.22.0
 - 0.21.0
 - 0.20.0
 - 0.19.0
 - 0.18.0
 - 0.17.0
 - 0.16.0
 - 0.15.0
 - 0.13.0
 - 0.12.0
 - 0.11.0
 - 0.10.0
 - 0.9.0
 - 0.8.0
 - 0.5.0
 
public interface TopologyConfigOrBuilder extends MessageOrBuilderImplements
MessageOrBuilderMethods
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 | |
|---|---|
| Name | Description | 
key | 
        String | 
      
| Returns | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Name | Description | 
index | 
        int | 
      
| Returns | |
|---|---|
| Type | Description | 
ComputationTopology | 
        |
getComputationsCount()
public abstract int getComputationsCount()The computations associated with a streaming Dataflow job.
 repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
| Returns | |
|---|---|
| Type | Description | 
int | 
        |
getComputationsList()
public abstract List<ComputationTopology> getComputationsList()The computations associated with a streaming Dataflow job.
 repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
| Returns | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Name | Description | 
index | 
        int | 
      
| Returns | |
|---|---|
| Type | Description | 
ComputationTopologyOrBuilder | 
        |
getComputationsOrBuilderList()
public abstract List<? extends ComputationTopologyOrBuilder> getComputationsOrBuilderList()The computations associated with a streaming Dataflow job.
 repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
| Returns | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Name | Description | 
index | 
        int | 
      
| Returns | |
|---|---|
| Type | Description | 
DataDiskAssignment | 
        |
getDataDiskAssignmentsCount()
public abstract int getDataDiskAssignmentsCount()The disks assigned to a streaming Dataflow job.
 repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;
| Returns | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Name | Description | 
index | 
        int | 
      
| Returns | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Type | Description | 
int | 
        The forwardingKeyBits.  | 
      
getPersistentStateVersion()
public abstract int getPersistentStateVersion()Version number for persistent state.
 int32 persistent_state_version = 5;
| Returns | |
|---|---|
| Type | Description | 
int | 
        The persistentStateVersion.  | 
      
getUserStageToComputationNameMap() (deprecated)
public abstract Map<String,String> getUserStageToComputationNameMap()Use #getUserStageToComputationNameMapMap() instead.
| Returns | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Name | Description | 
key | 
        String | 
      
defaultValue | 
        String | 
      
| Returns | |
|---|---|
| Type | Description | 
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 | |
|---|---|
| Name | Description | 
key | 
        String | 
      
| Returns | |
|---|---|
| Type | Description | 
String | 
        |