Reference documentation and code samples for the Dataflow V1beta3 API class Google::Cloud::Dataflow::V1beta3::StreamLocation.
Describes a stream of data, either as input to be processed or as output of a streaming Dataflow job.
Inherits
- Object
Extended By
- Google::Protobuf::MessageExts::ClassMethods
Includes
- Google::Protobuf::MessageExts
Methods
#custom_source_location
def custom_source_location() -> ::Google::Cloud::Dataflow::V1beta3::CustomSourceLocation
Returns
- (::Google::Cloud::Dataflow::V1beta3::CustomSourceLocation) — The stream is a custom source.
#custom_source_location=
def custom_source_location=(value) -> ::Google::Cloud::Dataflow::V1beta3::CustomSourceLocation
Parameter
- value (::Google::Cloud::Dataflow::V1beta3::CustomSourceLocation) — The stream is a custom source.
Returns
- (::Google::Cloud::Dataflow::V1beta3::CustomSourceLocation) — The stream is a custom source.
#pubsub_location
def pubsub_location() -> ::Google::Cloud::Dataflow::V1beta3::PubsubLocation
Returns
- (::Google::Cloud::Dataflow::V1beta3::PubsubLocation) — The stream is a pubsub stream.
#pubsub_location=
def pubsub_location=(value) -> ::Google::Cloud::Dataflow::V1beta3::PubsubLocation
Parameter
- value (::Google::Cloud::Dataflow::V1beta3::PubsubLocation) — The stream is a pubsub stream.
Returns
- (::Google::Cloud::Dataflow::V1beta3::PubsubLocation) — The stream is a pubsub stream.
#side_input_location
def side_input_location() -> ::Google::Cloud::Dataflow::V1beta3::StreamingSideInputLocation
Returns
- (::Google::Cloud::Dataflow::V1beta3::StreamingSideInputLocation) — The stream is a streaming side input.
#side_input_location=
def side_input_location=(value) -> ::Google::Cloud::Dataflow::V1beta3::StreamingSideInputLocation
Parameter
- value (::Google::Cloud::Dataflow::V1beta3::StreamingSideInputLocation) — The stream is a streaming side input.
Returns
- (::Google::Cloud::Dataflow::V1beta3::StreamingSideInputLocation) — The stream is a streaming side input.
#streaming_stage_location
def streaming_stage_location() -> ::Google::Cloud::Dataflow::V1beta3::StreamingStageLocation
Returns
- (::Google::Cloud::Dataflow::V1beta3::StreamingStageLocation) — The stream is part of another computation within the current streaming Dataflow job.
#streaming_stage_location=
def streaming_stage_location=(value) -> ::Google::Cloud::Dataflow::V1beta3::StreamingStageLocation
Parameter
- value (::Google::Cloud::Dataflow::V1beta3::StreamingStageLocation) — The stream is part of another computation within the current streaming Dataflow job.
Returns
- (::Google::Cloud::Dataflow::V1beta3::StreamingStageLocation) — The stream is part of another computation within the current streaming Dataflow job.