Uses of Class
com.google.dataflow.v1beta3.StreamLocation.Builder
-
Uses of StreamLocation.Builder in com.google.dataflow.v1beta3
Methods in com.google.dataflow.v1beta3 that return StreamLocation.BuilderModifier and TypeMethodDescriptionComputationTopology.Builder.addInputsBuilder()The inputs to the computation.ComputationTopology.Builder.addInputsBuilder(int index) The inputs to the computation.ComputationTopology.Builder.addOutputsBuilder()The outputs from the computation.ComputationTopology.Builder.addOutputsBuilder(int index) The outputs from the computation.StreamLocation.Builder.clear()StreamLocation.Builder.clearCustomSourceLocation()The stream is a custom source.StreamLocation.Builder.clearLocation()StreamLocation.Builder.clearPubsubLocation()The stream is a pubsub stream.StreamLocation.Builder.clearSideInputLocation()The stream is a streaming side input.StreamLocation.Builder.clearStreamingStageLocation()The stream is part of another computation within the current streaming Dataflow job.ComputationTopology.Builder.getInputsBuilder(int index) The inputs to the computation.ComputationTopology.Builder.getOutputsBuilder(int index) The outputs from the computation.StreamLocation.Builder.mergeCustomSourceLocation(CustomSourceLocation value) The stream is a custom source.StreamLocation.Builder.mergeFrom(StreamLocation other) StreamLocation.Builder.mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) StreamLocation.Builder.mergeFrom(com.google.protobuf.Message other) StreamLocation.Builder.mergePubsubLocation(PubsubLocation value) The stream is a pubsub stream.StreamLocation.Builder.mergeSideInputLocation(StreamingSideInputLocation value) The stream is a streaming side input.StreamLocation.Builder.mergeStreamingStageLocation(StreamingStageLocation value) The stream is part of another computation within the current streaming Dataflow job.static StreamLocation.BuilderStreamLocation.newBuilder()static StreamLocation.BuilderStreamLocation.newBuilder(StreamLocation prototype) StreamLocation.newBuilderForType()protected StreamLocation.BuilderStreamLocation.newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) StreamLocation.Builder.setCustomSourceLocation(CustomSourceLocation value) The stream is a custom source.StreamLocation.Builder.setCustomSourceLocation(CustomSourceLocation.Builder builderForValue) The stream is a custom source.StreamLocation.Builder.setPubsubLocation(PubsubLocation value) The stream is a pubsub stream.StreamLocation.Builder.setPubsubLocation(PubsubLocation.Builder builderForValue) The stream is a pubsub stream.StreamLocation.Builder.setSideInputLocation(StreamingSideInputLocation value) The stream is a streaming side input.StreamLocation.Builder.setSideInputLocation(StreamingSideInputLocation.Builder builderForValue) The stream is a streaming side input.StreamLocation.Builder.setStreamingStageLocation(StreamingStageLocation value) The stream is part of another computation within the current streaming Dataflow job.StreamLocation.Builder.setStreamingStageLocation(StreamingStageLocation.Builder builderForValue) The stream is part of another computation within the current streaming Dataflow job.StreamLocation.toBuilder()Methods in com.google.dataflow.v1beta3 that return types with arguments of type StreamLocation.BuilderModifier and TypeMethodDescriptionComputationTopology.Builder.getInputsBuilderList()The inputs to the computation.ComputationTopology.Builder.getOutputsBuilderList()The outputs from the computation.Methods in com.google.dataflow.v1beta3 with parameters of type StreamLocation.BuilderModifier and TypeMethodDescriptionComputationTopology.Builder.addInputs(int index, StreamLocation.Builder builderForValue) The inputs to the computation.ComputationTopology.Builder.addInputs(StreamLocation.Builder builderForValue) The inputs to the computation.ComputationTopology.Builder.addOutputs(int index, StreamLocation.Builder builderForValue) The outputs from the computation.ComputationTopology.Builder.addOutputs(StreamLocation.Builder builderForValue) The outputs from the computation.ComputationTopology.Builder.setInputs(int index, StreamLocation.Builder builderForValue) The inputs to the computation.ComputationTopology.Builder.setOutputs(int index, StreamLocation.Builder builderForValue) The outputs from the computation.