- 0.55.0 (latest)
- 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 static final class ComputationTopology.Builder extends GeneratedMessageV3.Builder<ComputationTopology.Builder> implements ComputationTopologyOrBuilder
All configuration data for a particular Computation.
Protobuf type google.dataflow.v1beta3.ComputationTopology
Inheritance
Object > AbstractMessageLite.Builder<MessageType,BuilderType> > AbstractMessage.Builder<BuilderType> > GeneratedMessageV3.Builder > ComputationTopology.BuilderImplements
ComputationTopologyOrBuilderStatic Methods
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Returns | |
---|---|
Type | Description |
Descriptor |
Methods
addAllInputs(Iterable<? extends StreamLocation> values)
public ComputationTopology.Builder addAllInputs(Iterable<? extends StreamLocation> values)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter | |
---|---|
Name | Description |
values |
Iterable<? extends com.google.dataflow.v1beta3.StreamLocation> |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addAllKeyRanges(Iterable<? extends KeyRangeLocation> values)
public ComputationTopology.Builder addAllKeyRanges(Iterable<? extends KeyRangeLocation> values)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter | |
---|---|
Name | Description |
values |
Iterable<? extends com.google.dataflow.v1beta3.KeyRangeLocation> |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addAllOutputs(Iterable<? extends StreamLocation> values)
public ComputationTopology.Builder addAllOutputs(Iterable<? extends StreamLocation> values)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter | |
---|---|
Name | Description |
values |
Iterable<? extends com.google.dataflow.v1beta3.StreamLocation> |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addAllStateFamilies(Iterable<? extends StateFamilyConfig> values)
public ComputationTopology.Builder addAllStateFamilies(Iterable<? extends StateFamilyConfig> values)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter | |
---|---|
Name | Description |
values |
Iterable<? extends com.google.dataflow.v1beta3.StateFamilyConfig> |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addInputs(StreamLocation value)
public ComputationTopology.Builder addInputs(StreamLocation value)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter | |
---|---|
Name | Description |
value |
StreamLocation |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addInputs(StreamLocation.Builder builderForValue)
public ComputationTopology.Builder addInputs(StreamLocation.Builder builderForValue)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter | |
---|---|
Name | Description |
builderForValue |
StreamLocation.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addInputs(int index, StreamLocation value)
public ComputationTopology.Builder addInputs(int index, StreamLocation value)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameters | |
---|---|
Name | Description |
index |
int |
value |
StreamLocation |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addInputs(int index, StreamLocation.Builder builderForValue)
public ComputationTopology.Builder addInputs(int index, StreamLocation.Builder builderForValue)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameters | |
---|---|
Name | Description |
index |
int |
builderForValue |
StreamLocation.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addInputsBuilder()
public StreamLocation.Builder addInputsBuilder()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Returns | |
---|---|
Type | Description |
StreamLocation.Builder |
addInputsBuilder(int index)
public StreamLocation.Builder addInputsBuilder(int index)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StreamLocation.Builder |
addKeyRanges(KeyRangeLocation value)
public ComputationTopology.Builder addKeyRanges(KeyRangeLocation value)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter | |
---|---|
Name | Description |
value |
KeyRangeLocation |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addKeyRanges(KeyRangeLocation.Builder builderForValue)
public ComputationTopology.Builder addKeyRanges(KeyRangeLocation.Builder builderForValue)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter | |
---|---|
Name | Description |
builderForValue |
KeyRangeLocation.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addKeyRanges(int index, KeyRangeLocation value)
public ComputationTopology.Builder addKeyRanges(int index, KeyRangeLocation value)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameters | |
---|---|
Name | Description |
index |
int |
value |
KeyRangeLocation |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addKeyRanges(int index, KeyRangeLocation.Builder builderForValue)
public ComputationTopology.Builder addKeyRanges(int index, KeyRangeLocation.Builder builderForValue)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameters | |
---|---|
Name | Description |
index |
int |
builderForValue |
KeyRangeLocation.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addKeyRangesBuilder()
public KeyRangeLocation.Builder addKeyRangesBuilder()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Returns | |
---|---|
Type | Description |
KeyRangeLocation.Builder |
addKeyRangesBuilder(int index)
public KeyRangeLocation.Builder addKeyRangesBuilder(int index)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
KeyRangeLocation.Builder |
addOutputs(StreamLocation value)
public ComputationTopology.Builder addOutputs(StreamLocation value)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter | |
---|---|
Name | Description |
value |
StreamLocation |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addOutputs(StreamLocation.Builder builderForValue)
public ComputationTopology.Builder addOutputs(StreamLocation.Builder builderForValue)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter | |
---|---|
Name | Description |
builderForValue |
StreamLocation.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addOutputs(int index, StreamLocation value)
public ComputationTopology.Builder addOutputs(int index, StreamLocation value)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameters | |
---|---|
Name | Description |
index |
int |
value |
StreamLocation |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addOutputs(int index, StreamLocation.Builder builderForValue)
public ComputationTopology.Builder addOutputs(int index, StreamLocation.Builder builderForValue)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameters | |
---|---|
Name | Description |
index |
int |
builderForValue |
StreamLocation.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addOutputsBuilder()
public StreamLocation.Builder addOutputsBuilder()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Returns | |
---|---|
Type | Description |
StreamLocation.Builder |
addOutputsBuilder(int index)
public StreamLocation.Builder addOutputsBuilder(int index)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StreamLocation.Builder |
addRepeatedField(Descriptors.FieldDescriptor field, Object value)
public ComputationTopology.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Parameters | |
---|---|
Name | Description |
field |
FieldDescriptor |
value |
Object |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addStateFamilies(StateFamilyConfig value)
public ComputationTopology.Builder addStateFamilies(StateFamilyConfig value)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter | |
---|---|
Name | Description |
value |
StateFamilyConfig |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addStateFamilies(StateFamilyConfig.Builder builderForValue)
public ComputationTopology.Builder addStateFamilies(StateFamilyConfig.Builder builderForValue)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter | |
---|---|
Name | Description |
builderForValue |
StateFamilyConfig.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addStateFamilies(int index, StateFamilyConfig value)
public ComputationTopology.Builder addStateFamilies(int index, StateFamilyConfig value)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameters | |
---|---|
Name | Description |
index |
int |
value |
StateFamilyConfig |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addStateFamilies(int index, StateFamilyConfig.Builder builderForValue)
public ComputationTopology.Builder addStateFamilies(int index, StateFamilyConfig.Builder builderForValue)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameters | |
---|---|
Name | Description |
index |
int |
builderForValue |
StateFamilyConfig.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
addStateFamiliesBuilder()
public StateFamilyConfig.Builder addStateFamiliesBuilder()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Returns | |
---|---|
Type | Description |
StateFamilyConfig.Builder |
addStateFamiliesBuilder(int index)
public StateFamilyConfig.Builder addStateFamiliesBuilder(int index)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StateFamilyConfig.Builder |
build()
public ComputationTopology build()
Returns | |
---|---|
Type | Description |
ComputationTopology |
buildPartial()
public ComputationTopology buildPartial()
Returns | |
---|---|
Type | Description |
ComputationTopology |
clear()
public ComputationTopology.Builder clear()
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
clearComputationId()
public ComputationTopology.Builder clearComputationId()
The ID of the computation.
string computation_id = 5;
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
This builder for chaining. |
clearField(Descriptors.FieldDescriptor field)
public ComputationTopology.Builder clearField(Descriptors.FieldDescriptor field)
Parameter | |
---|---|
Name | Description |
field |
FieldDescriptor |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
clearInputs()
public ComputationTopology.Builder clearInputs()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
clearKeyRanges()
public ComputationTopology.Builder clearKeyRanges()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
clearOneof(Descriptors.OneofDescriptor oneof)
public ComputationTopology.Builder clearOneof(Descriptors.OneofDescriptor oneof)
Parameter | |
---|---|
Name | Description |
oneof |
OneofDescriptor |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
clearOutputs()
public ComputationTopology.Builder clearOutputs()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
clearStateFamilies()
public ComputationTopology.Builder clearStateFamilies()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
clearSystemStageName()
public ComputationTopology.Builder clearSystemStageName()
The system stage name.
string system_stage_name = 1;
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
This builder for chaining. |
clone()
public ComputationTopology.Builder clone()
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
getComputationId()
public String getComputationId()
The ID of the computation.
string computation_id = 5;
Returns | |
---|---|
Type | Description |
String |
The computationId. |
getComputationIdBytes()
public ByteString getComputationIdBytes()
The ID of the computation.
string computation_id = 5;
Returns | |
---|---|
Type | Description |
ByteString |
The bytes for computationId. |
getDefaultInstanceForType()
public ComputationTopology getDefaultInstanceForType()
Returns | |
---|---|
Type | Description |
ComputationTopology |
getDescriptorForType()
public Descriptors.Descriptor getDescriptorForType()
Returns | |
---|---|
Type | Description |
Descriptor |
getInputs(int index)
public StreamLocation getInputs(int index)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StreamLocation |
getInputsBuilder(int index)
public StreamLocation.Builder getInputsBuilder(int index)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StreamLocation.Builder |
getInputsBuilderList()
public List<StreamLocation.Builder> getInputsBuilderList()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Returns | |
---|---|
Type | Description |
List<Builder> |
getInputsCount()
public int getInputsCount()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Returns | |
---|---|
Type | Description |
int |
getInputsList()
public List<StreamLocation> getInputsList()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Returns | |
---|---|
Type | Description |
List<StreamLocation> |
getInputsOrBuilder(int index)
public StreamLocationOrBuilder getInputsOrBuilder(int index)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StreamLocationOrBuilder |
getInputsOrBuilderList()
public List<? extends StreamLocationOrBuilder> getInputsOrBuilderList()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Returns | |
---|---|
Type | Description |
List<? extends com.google.dataflow.v1beta3.StreamLocationOrBuilder> |
getKeyRanges(int index)
public KeyRangeLocation getKeyRanges(int index)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
KeyRangeLocation |
getKeyRangesBuilder(int index)
public KeyRangeLocation.Builder getKeyRangesBuilder(int index)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
KeyRangeLocation.Builder |
getKeyRangesBuilderList()
public List<KeyRangeLocation.Builder> getKeyRangesBuilderList()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Returns | |
---|---|
Type | Description |
List<Builder> |
getKeyRangesCount()
public int getKeyRangesCount()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Returns | |
---|---|
Type | Description |
int |
getKeyRangesList()
public List<KeyRangeLocation> getKeyRangesList()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Returns | |
---|---|
Type | Description |
List<KeyRangeLocation> |
getKeyRangesOrBuilder(int index)
public KeyRangeLocationOrBuilder getKeyRangesOrBuilder(int index)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
KeyRangeLocationOrBuilder |
getKeyRangesOrBuilderList()
public List<? extends KeyRangeLocationOrBuilder> getKeyRangesOrBuilderList()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Returns | |
---|---|
Type | Description |
List<? extends com.google.dataflow.v1beta3.KeyRangeLocationOrBuilder> |
getOutputs(int index)
public StreamLocation getOutputs(int index)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StreamLocation |
getOutputsBuilder(int index)
public StreamLocation.Builder getOutputsBuilder(int index)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StreamLocation.Builder |
getOutputsBuilderList()
public List<StreamLocation.Builder> getOutputsBuilderList()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Returns | |
---|---|
Type | Description |
List<Builder> |
getOutputsCount()
public int getOutputsCount()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Returns | |
---|---|
Type | Description |
int |
getOutputsList()
public List<StreamLocation> getOutputsList()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Returns | |
---|---|
Type | Description |
List<StreamLocation> |
getOutputsOrBuilder(int index)
public StreamLocationOrBuilder getOutputsOrBuilder(int index)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StreamLocationOrBuilder |
getOutputsOrBuilderList()
public List<? extends StreamLocationOrBuilder> getOutputsOrBuilderList()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Returns | |
---|---|
Type | Description |
List<? extends com.google.dataflow.v1beta3.StreamLocationOrBuilder> |
getStateFamilies(int index)
public StateFamilyConfig getStateFamilies(int index)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StateFamilyConfig |
getStateFamiliesBuilder(int index)
public StateFamilyConfig.Builder getStateFamiliesBuilder(int index)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StateFamilyConfig.Builder |
getStateFamiliesBuilderList()
public List<StateFamilyConfig.Builder> getStateFamiliesBuilderList()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Returns | |
---|---|
Type | Description |
List<Builder> |
getStateFamiliesCount()
public int getStateFamiliesCount()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Returns | |
---|---|
Type | Description |
int |
getStateFamiliesList()
public List<StateFamilyConfig> getStateFamiliesList()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Returns | |
---|---|
Type | Description |
List<StateFamilyConfig> |
getStateFamiliesOrBuilder(int index)
public StateFamilyConfigOrBuilder getStateFamiliesOrBuilder(int index)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
StateFamilyConfigOrBuilder |
getStateFamiliesOrBuilderList()
public List<? extends StateFamilyConfigOrBuilder> getStateFamiliesOrBuilderList()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Returns | |
---|---|
Type | Description |
List<? extends com.google.dataflow.v1beta3.StateFamilyConfigOrBuilder> |
getSystemStageName()
public String getSystemStageName()
The system stage name.
string system_stage_name = 1;
Returns | |
---|---|
Type | Description |
String |
The systemStageName. |
getSystemStageNameBytes()
public ByteString getSystemStageNameBytes()
The system stage name.
string system_stage_name = 1;
Returns | |
---|---|
Type | Description |
ByteString |
The bytes for systemStageName. |
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns | |
---|---|
Type | Description |
FieldAccessorTable |
isInitialized()
public final boolean isInitialized()
Returns | |
---|---|
Type | Description |
boolean |
mergeFrom(ComputationTopology other)
public ComputationTopology.Builder mergeFrom(ComputationTopology other)
Parameter | |
---|---|
Name | Description |
other |
ComputationTopology |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public ComputationTopology.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters | |
---|---|
Name | Description |
input |
CodedInputStream |
extensionRegistry |
ExtensionRegistryLite |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
Exceptions | |
---|---|
Type | Description |
IOException |
mergeFrom(Message other)
public ComputationTopology.Builder mergeFrom(Message other)
Parameter | |
---|---|
Name | Description |
other |
Message |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
mergeUnknownFields(UnknownFieldSet unknownFields)
public final ComputationTopology.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Parameter | |
---|---|
Name | Description |
unknownFields |
UnknownFieldSet |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
removeInputs(int index)
public ComputationTopology.Builder removeInputs(int index)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
removeKeyRanges(int index)
public ComputationTopology.Builder removeKeyRanges(int index)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
removeOutputs(int index)
public ComputationTopology.Builder removeOutputs(int index)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
removeStateFamilies(int index)
public ComputationTopology.Builder removeStateFamilies(int index)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter | |
---|---|
Name | Description |
index |
int |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setComputationId(String value)
public ComputationTopology.Builder setComputationId(String value)
The ID of the computation.
string computation_id = 5;
Parameter | |
---|---|
Name | Description |
value |
String The computationId to set. |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
This builder for chaining. |
setComputationIdBytes(ByteString value)
public ComputationTopology.Builder setComputationIdBytes(ByteString value)
The ID of the computation.
string computation_id = 5;
Parameter | |
---|---|
Name | Description |
value |
ByteString The bytes for computationId to set. |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
This builder for chaining. |
setField(Descriptors.FieldDescriptor field, Object value)
public ComputationTopology.Builder setField(Descriptors.FieldDescriptor field, Object value)
Parameters | |
---|---|
Name | Description |
field |
FieldDescriptor |
value |
Object |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setInputs(int index, StreamLocation value)
public ComputationTopology.Builder setInputs(int index, StreamLocation value)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameters | |
---|---|
Name | Description |
index |
int |
value |
StreamLocation |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setInputs(int index, StreamLocation.Builder builderForValue)
public ComputationTopology.Builder setInputs(int index, StreamLocation.Builder builderForValue)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameters | |
---|---|
Name | Description |
index |
int |
builderForValue |
StreamLocation.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setKeyRanges(int index, KeyRangeLocation value)
public ComputationTopology.Builder setKeyRanges(int index, KeyRangeLocation value)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameters | |
---|---|
Name | Description |
index |
int |
value |
KeyRangeLocation |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setKeyRanges(int index, KeyRangeLocation.Builder builderForValue)
public ComputationTopology.Builder setKeyRanges(int index, KeyRangeLocation.Builder builderForValue)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameters | |
---|---|
Name | Description |
index |
int |
builderForValue |
KeyRangeLocation.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setOutputs(int index, StreamLocation value)
public ComputationTopology.Builder setOutputs(int index, StreamLocation value)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameters | |
---|---|
Name | Description |
index |
int |
value |
StreamLocation |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setOutputs(int index, StreamLocation.Builder builderForValue)
public ComputationTopology.Builder setOutputs(int index, StreamLocation.Builder builderForValue)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameters | |
---|---|
Name | Description |
index |
int |
builderForValue |
StreamLocation.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
public ComputationTopology.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
Parameters | |
---|---|
Name | Description |
field |
FieldDescriptor |
index |
int |
value |
Object |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setStateFamilies(int index, StateFamilyConfig value)
public ComputationTopology.Builder setStateFamilies(int index, StateFamilyConfig value)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameters | |
---|---|
Name | Description |
index |
int |
value |
StateFamilyConfig |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setStateFamilies(int index, StateFamilyConfig.Builder builderForValue)
public ComputationTopology.Builder setStateFamilies(int index, StateFamilyConfig.Builder builderForValue)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameters | |
---|---|
Name | Description |
index |
int |
builderForValue |
StateFamilyConfig.Builder |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
setSystemStageName(String value)
public ComputationTopology.Builder setSystemStageName(String value)
The system stage name.
string system_stage_name = 1;
Parameter | |
---|---|
Name | Description |
value |
String The systemStageName to set. |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
This builder for chaining. |
setSystemStageNameBytes(ByteString value)
public ComputationTopology.Builder setSystemStageNameBytes(ByteString value)
The system stage name.
string system_stage_name = 1;
Parameter | |
---|---|
Name | Description |
value |
ByteString The bytes for systemStageName to set. |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |
This builder for chaining. |
setUnknownFields(UnknownFieldSet unknownFields)
public final ComputationTopology.Builder setUnknownFields(UnknownFieldSet unknownFields)
Parameter | |
---|---|
Name | Description |
unknownFields |
UnknownFieldSet |
Returns | |
---|---|
Type | Description |
ComputationTopology.Builder |