Class Google::Cloud::Dataflow::V1beta3::StreamLocation (v0.1.4)

Version 0.1.4

• 0.9.1 (latest)
• 0.9.0
• 0.8.2
• 0.7.0
• 0.6.0
• 0.5.0
• 0.4.0
• 0.3.0
• 0.2.0
• 0.1.4

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.