Dataflow V1beta3 API - Class Google::Cloud::Dataflow::V1beta3::StreamLocation (v0.14.0)

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.

    Note: The following fields are mutually exclusive: custom_source_location, streaming_stage_location, pubsub_location, side_input_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

#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.

    Note: The following fields are mutually exclusive: custom_source_location, streaming_stage_location, pubsub_location, side_input_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

Returns
  • (::Google::Cloud::Dataflow::V1beta3::CustomSourceLocation) — The stream is a custom source.

    Note: The following fields are mutually exclusive: custom_source_location, streaming_stage_location, pubsub_location, side_input_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

#pubsub_location

def pubsub_location() -> ::Google::Cloud::Dataflow::V1beta3::PubsubLocation
Returns
  • (::Google::Cloud::Dataflow::V1beta3::PubsubLocation) — The stream is a pubsub stream.

    Note: The following fields are mutually exclusive: pubsub_location, streaming_stage_location, side_input_location, custom_source_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

#pubsub_location=

def pubsub_location=(value) -> ::Google::Cloud::Dataflow::V1beta3::PubsubLocation
Parameter
  • value (::Google::Cloud::Dataflow::V1beta3::PubsubLocation) — The stream is a pubsub stream.

    Note: The following fields are mutually exclusive: pubsub_location, streaming_stage_location, side_input_location, custom_source_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

Returns
  • (::Google::Cloud::Dataflow::V1beta3::PubsubLocation) — The stream is a pubsub stream.

    Note: The following fields are mutually exclusive: pubsub_location, streaming_stage_location, side_input_location, custom_source_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

#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.

    Note: The following fields are mutually exclusive: side_input_location, streaming_stage_location, pubsub_location, custom_source_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

#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.

    Note: The following fields are mutually exclusive: side_input_location, streaming_stage_location, pubsub_location, custom_source_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

Returns
  • (::Google::Cloud::Dataflow::V1beta3::StreamingSideInputLocation) — The stream is a streaming side input.

    Note: The following fields are mutually exclusive: side_input_location, streaming_stage_location, pubsub_location, custom_source_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

#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.

    Note: The following fields are mutually exclusive: streaming_stage_location, pubsub_location, side_input_location, custom_source_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

#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.

    Note: The following fields are mutually exclusive: streaming_stage_location, pubsub_location, side_input_location, custom_source_location. If a field in that set is populated, all other fields in the set will automatically be cleared.

Returns
  • (::Google::Cloud::Dataflow::V1beta3::StreamingStageLocation) — The stream is part of another computation within the current streaming Dataflow job.

    Note: The following fields are mutually exclusive: streaming_stage_location, pubsub_location, side_input_location, custom_source_location. If a field in that set is populated, all other fields in the set will automatically be cleared.