Google Cloud Dataflow V1beta3 Client - Class StreamLocation (0.6.6)

Reference documentation and code samples for the Google Cloud Dataflow V1beta3 Client class StreamLocation.

Describes a stream of data, either as input to be processed or as output of a streaming Dataflow job.

Generated from protobuf message google.dataflow.v1beta3.StreamLocation

Namespace

Google \ Cloud \ Dataflow \ V1beta3

Methods

__construct

Constructor.

Parameters
Name Description
data array

Optional. Data for populating the Message object.

↳ streaming_stage_location StreamingStageLocation

The stream is part of another computation within the current streaming Dataflow job.

↳ pubsub_location PubsubLocation

The stream is a pubsub stream.

↳ side_input_location StreamingSideInputLocation

The stream is a streaming side input.

↳ custom_source_location CustomSourceLocation

The stream is a custom source.

getStreamingStageLocation

The stream is part of another computation within the current streaming Dataflow job.

Returns
Type Description
StreamingStageLocation|null

hasStreamingStageLocation

setStreamingStageLocation

The stream is part of another computation within the current streaming Dataflow job.

Parameter
Name Description
var StreamingStageLocation
Returns
Type Description
$this

getPubsubLocation

The stream is a pubsub stream.

Returns
Type Description
PubsubLocation|null

hasPubsubLocation

setPubsubLocation

The stream is a pubsub stream.

Parameter
Name Description
var PubsubLocation
Returns
Type Description
$this

getSideInputLocation

The stream is a streaming side input.

Returns
Type Description
StreamingSideInputLocation|null

hasSideInputLocation

setSideInputLocation

The stream is a streaming side input.

Parameter
Name Description
var StreamingSideInputLocation
Returns
Type Description
$this

getCustomSourceLocation

The stream is a custom source.

Returns
Type Description
CustomSourceLocation|null

hasCustomSourceLocation

setCustomSourceLocation

The stream is a custom source.

Parameter
Name Description
var CustomSourceLocation
Returns
Type Description
$this

getLocation

Returns
Type Description
string