Uses of Class
com.google.dataflow.v1beta3.ComputationTopology.Builder
-
Uses of ComputationTopology.Builder in com.google.dataflow.v1beta3
Methods in com.google.dataflow.v1beta3 that return ComputationTopology.BuilderModifier and TypeMethodDescriptionComputationTopology.Builder.addAllInputs(Iterable<? extends StreamLocation> values) The inputs to the computation.ComputationTopology.Builder.addAllKeyRanges(Iterable<? extends KeyRangeLocation> values) The key ranges processed by the computation.ComputationTopology.Builder.addAllOutputs(Iterable<? extends StreamLocation> values) The outputs from the computation.ComputationTopology.Builder.addAllStateFamilies(Iterable<? extends StateFamilyConfig> values) The state family values.TopologyConfig.Builder.addComputationsBuilder()The computations associated with a streaming Dataflow job.TopologyConfig.Builder.addComputationsBuilder(int index) The computations associated with a streaming Dataflow job.ComputationTopology.Builder.addInputs(int index, StreamLocation value) The inputs to the computation.ComputationTopology.Builder.addInputs(int index, StreamLocation.Builder builderForValue) The inputs to the computation.ComputationTopology.Builder.addInputs(StreamLocation value) The inputs to the computation.ComputationTopology.Builder.addInputs(StreamLocation.Builder builderForValue) The inputs to the computation.ComputationTopology.Builder.addKeyRanges(int index, KeyRangeLocation value) The key ranges processed by the computation.ComputationTopology.Builder.addKeyRanges(int index, KeyRangeLocation.Builder builderForValue) The key ranges processed by the computation.ComputationTopology.Builder.addKeyRanges(KeyRangeLocation value) The key ranges processed by the computation.ComputationTopology.Builder.addKeyRanges(KeyRangeLocation.Builder builderForValue) The key ranges processed by the computation.ComputationTopology.Builder.addOutputs(int index, StreamLocation value) The outputs from the computation.ComputationTopology.Builder.addOutputs(int index, StreamLocation.Builder builderForValue) The outputs from the computation.ComputationTopology.Builder.addOutputs(StreamLocation value) The outputs from the computation.ComputationTopology.Builder.addOutputs(StreamLocation.Builder builderForValue) The outputs from the computation.ComputationTopology.Builder.addStateFamilies(int index, StateFamilyConfig value) The state family values.ComputationTopology.Builder.addStateFamilies(int index, StateFamilyConfig.Builder builderForValue) The state family values.ComputationTopology.Builder.addStateFamilies(StateFamilyConfig value) The state family values.ComputationTopology.Builder.addStateFamilies(StateFamilyConfig.Builder builderForValue) The state family values.ComputationTopology.Builder.clear()ComputationTopology.Builder.clearComputationId()The ID of the computation.ComputationTopology.Builder.clearInputs()The inputs to the computation.ComputationTopology.Builder.clearKeyRanges()The key ranges processed by the computation.ComputationTopology.Builder.clearOutputs()The outputs from the computation.ComputationTopology.Builder.clearStateFamilies()The state family values.ComputationTopology.Builder.clearSystemStageName()The system stage name.TopologyConfig.Builder.getComputationsBuilder(int index) The computations associated with a streaming Dataflow job.ComputationTopology.Builder.mergeFrom(ComputationTopology other) ComputationTopology.Builder.mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) ComputationTopology.Builder.mergeFrom(com.google.protobuf.Message other) static ComputationTopology.BuilderComputationTopology.newBuilder()static ComputationTopology.BuilderComputationTopology.newBuilder(ComputationTopology prototype) ComputationTopology.newBuilderForType()protected ComputationTopology.BuilderComputationTopology.newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) ComputationTopology.Builder.removeInputs(int index) The inputs to the computation.ComputationTopology.Builder.removeKeyRanges(int index) The key ranges processed by the computation.ComputationTopology.Builder.removeOutputs(int index) The outputs from the computation.ComputationTopology.Builder.removeStateFamilies(int index) The state family values.ComputationTopology.Builder.setComputationId(String value) The ID of the computation.ComputationTopology.Builder.setComputationIdBytes(com.google.protobuf.ByteString value) The ID of the computation.ComputationTopology.Builder.setInputs(int index, StreamLocation value) The inputs to the computation.ComputationTopology.Builder.setInputs(int index, StreamLocation.Builder builderForValue) The inputs to the computation.ComputationTopology.Builder.setKeyRanges(int index, KeyRangeLocation value) The key ranges processed by the computation.ComputationTopology.Builder.setKeyRanges(int index, KeyRangeLocation.Builder builderForValue) The key ranges processed by the computation.ComputationTopology.Builder.setOutputs(int index, StreamLocation value) The outputs from the computation.ComputationTopology.Builder.setOutputs(int index, StreamLocation.Builder builderForValue) The outputs from the computation.ComputationTopology.Builder.setStateFamilies(int index, StateFamilyConfig value) The state family values.ComputationTopology.Builder.setStateFamilies(int index, StateFamilyConfig.Builder builderForValue) The state family values.ComputationTopology.Builder.setSystemStageName(String value) The system stage name.ComputationTopology.Builder.setSystemStageNameBytes(com.google.protobuf.ByteString value) The system stage name.ComputationTopology.toBuilder()Methods in com.google.dataflow.v1beta3 that return types with arguments of type ComputationTopology.BuilderModifier and TypeMethodDescriptionTopologyConfig.Builder.getComputationsBuilderList()The computations associated with a streaming Dataflow job.Methods in com.google.dataflow.v1beta3 with parameters of type ComputationTopology.BuilderModifier and TypeMethodDescriptionTopologyConfig.Builder.addComputations(int index, ComputationTopology.Builder builderForValue) The computations associated with a streaming Dataflow job.TopologyConfig.Builder.addComputations(ComputationTopology.Builder builderForValue) The computations associated with a streaming Dataflow job.TopologyConfig.Builder.setComputations(int index, ComputationTopology.Builder builderForValue) The computations associated with a streaming Dataflow job.