public sealed class StreamLocation : IMessage<StreamLocation>, IEquatable<StreamLocation>, IDeepCloneable<StreamLocation>, IBufferMessage, IMessage
Describes a stream of data, either as input to be processed or as output of a streaming Dataflow job.
Implements
IMessage<StreamLocation>, IEquatable<StreamLocation>, IDeepCloneable<StreamLocation>, IBufferMessage, IMessageNamespace
Google.Cloud.Dataflow.V1Beta3Assembly
Google.Cloud.Dataflow.V1Beta3.dll
Constructors
StreamLocation()
public StreamLocation()
StreamLocation(StreamLocation)
public StreamLocation(StreamLocation other)
Parameter | |
---|---|
Name | Description |
other | StreamLocation |
Properties
CustomSourceLocation
public CustomSourceLocation CustomSourceLocation { get; set; }
The stream is a custom source.
Property Value | |
---|---|
Type | Description |
CustomSourceLocation |
LocationCase
public StreamLocation.LocationOneofCase LocationCase { get; }
Property Value | |
---|---|
Type | Description |
StreamLocation.LocationOneofCase |
PubsubLocation
public PubsubLocation PubsubLocation { get; set; }
The stream is a pubsub stream.
Property Value | |
---|---|
Type | Description |
PubsubLocation |
SideInputLocation
public StreamingSideInputLocation SideInputLocation { get; set; }
The stream is a streaming side input.
Property Value | |
---|---|
Type | Description |
StreamingSideInputLocation |
StreamingStageLocation
public StreamingStageLocation StreamingStageLocation { get; set; }
The stream is part of another computation within the current streaming Dataflow job.
Property Value | |
---|---|
Type | Description |
StreamingStageLocation |