StreamLocation(mapping=None, *, ignore_unknown_fields=False, **kwargs)
Describes a stream of data, either as input to be processed or as output of a streaming Dataflow job.
Attributes
Name | Description |
streaming_stage_location |
google.cloud.dataflow_v1beta3.types.StreamingStageLocation
The stream is part of another computation within the current streaming Dataflow job. |
pubsub_location |
google.cloud.dataflow_v1beta3.types.PubsubLocation
The stream is a pubsub stream. |
side_input_location |
google.cloud.dataflow_v1beta3.types.StreamingSideInputLocation
The stream is a streaming side input. |
custom_source_location |
google.cloud.dataflow_v1beta3.types.CustomSourceLocation
The stream is a custom source. |