public final class StreamLocation extends GeneratedMessageV3 implements StreamLocationOrBuilder
Describes a stream of data, either as input to be processed or as output of a streaming Dataflow job.
Protobuf type google.dataflow.v1beta3.StreamLocation
Inheritance
Object > AbstractMessageLite<MessageType,BuilderType> > AbstractMessage > GeneratedMessageV3 > StreamLocationImplements
StreamLocationOrBuilderStatic Fields
CUSTOM_SOURCE_LOCATION_FIELD_NUMBER
public static final int CUSTOM_SOURCE_LOCATION_FIELD_NUMBER
Type | Description |
int |
PUBSUB_LOCATION_FIELD_NUMBER
public static final int PUBSUB_LOCATION_FIELD_NUMBER
Type | Description |
int |
SIDE_INPUT_LOCATION_FIELD_NUMBER
public static final int SIDE_INPUT_LOCATION_FIELD_NUMBER
Type | Description |
int |
STREAMING_STAGE_LOCATION_FIELD_NUMBER
public static final int STREAMING_STAGE_LOCATION_FIELD_NUMBER
Type | Description |
int |
Static Methods
getDefaultInstance()
public static StreamLocation getDefaultInstance()
Type | Description |
StreamLocation |
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Type | Description |
Descriptor |
newBuilder()
public static StreamLocation.Builder newBuilder()
Type | Description |
StreamLocation.Builder |
newBuilder(StreamLocation prototype)
public static StreamLocation.Builder newBuilder(StreamLocation prototype)
Name | Description |
prototype | StreamLocation |
Type | Description |
StreamLocation.Builder |
parseDelimitedFrom(InputStream input)
public static StreamLocation parseDelimitedFrom(InputStream input)
Name | Description |
input | InputStream |
Type | Description |
StreamLocation |
Type | Description |
IOException |
parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
public static StreamLocation parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Name | Description |
input | InputStream |
extensionRegistry | ExtensionRegistryLite |
Type | Description |
StreamLocation |
Type | Description |
IOException |
parseFrom(byte[] data)
public static StreamLocation parseFrom(byte[] data)
Name | Description |
data | byte[] |
Type | Description |
StreamLocation |
Type | Description |
InvalidProtocolBufferException |
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static StreamLocation parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
Name | Description |
data | byte[] |
extensionRegistry | ExtensionRegistryLite |
Type | Description |
StreamLocation |
Type | Description |
InvalidProtocolBufferException |
parseFrom(ByteString data)
public static StreamLocation parseFrom(ByteString data)
Name | Description |
data | ByteString |
Type | Description |
StreamLocation |
Type | Description |
InvalidProtocolBufferException |
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static StreamLocation parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
Name | Description |
data | ByteString |
extensionRegistry | ExtensionRegistryLite |
Type | Description |
StreamLocation |
Type | Description |
InvalidProtocolBufferException |
parseFrom(CodedInputStream input)
public static StreamLocation parseFrom(CodedInputStream input)
Name | Description |
input | CodedInputStream |
Type | Description |
StreamLocation |
Type | Description |
IOException |
parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public static StreamLocation parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Name | Description |
input | CodedInputStream |
extensionRegistry | ExtensionRegistryLite |
Type | Description |
StreamLocation |
Type | Description |
IOException |
parseFrom(InputStream input)
public static StreamLocation parseFrom(InputStream input)
Name | Description |
input | InputStream |
Type | Description |
StreamLocation |
Type | Description |
IOException |
parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
public static StreamLocation parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Name | Description |
input | InputStream |
extensionRegistry | ExtensionRegistryLite |
Type | Description |
StreamLocation |
Type | Description |
IOException |
parseFrom(ByteBuffer data)
public static StreamLocation parseFrom(ByteBuffer data)
Name | Description |
data | ByteBuffer |
Type | Description |
StreamLocation |
Type | Description |
InvalidProtocolBufferException |
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static StreamLocation parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
Name | Description |
data | ByteBuffer |
extensionRegistry | ExtensionRegistryLite |
Type | Description |
StreamLocation |
Type | Description |
InvalidProtocolBufferException |
parser()
public static Parser<StreamLocation> parser()
Type | Description |
Parser<StreamLocation> |
Methods
equals(Object obj)
public boolean equals(Object obj)
Name | Description |
obj | Object |
Type | Description |
boolean |
getCustomSourceLocation()
public CustomSourceLocation getCustomSourceLocation()
The stream is a custom source.
.google.dataflow.v1beta3.CustomSourceLocation custom_source_location = 4;
Type | Description |
CustomSourceLocation | The customSourceLocation. |
getCustomSourceLocationOrBuilder()
public CustomSourceLocationOrBuilder getCustomSourceLocationOrBuilder()
The stream is a custom source.
.google.dataflow.v1beta3.CustomSourceLocation custom_source_location = 4;
Type | Description |
CustomSourceLocationOrBuilder |
getDefaultInstanceForType()
public StreamLocation getDefaultInstanceForType()
Type | Description |
StreamLocation |
getLocationCase()
public StreamLocation.LocationCase getLocationCase()
Type | Description |
StreamLocation.LocationCase |
getParserForType()
public Parser<StreamLocation> getParserForType()
Type | Description |
Parser<StreamLocation> |
getPubsubLocation()
public PubsubLocation getPubsubLocation()
The stream is a pubsub stream.
.google.dataflow.v1beta3.PubsubLocation pubsub_location = 2;
Type | Description |
PubsubLocation | The pubsubLocation. |
getPubsubLocationOrBuilder()
public PubsubLocationOrBuilder getPubsubLocationOrBuilder()
The stream is a pubsub stream.
.google.dataflow.v1beta3.PubsubLocation pubsub_location = 2;
Type | Description |
PubsubLocationOrBuilder |
getSerializedSize()
public int getSerializedSize()
Type | Description |
int |
getSideInputLocation()
public StreamingSideInputLocation getSideInputLocation()
The stream is a streaming side input.
.google.dataflow.v1beta3.StreamingSideInputLocation side_input_location = 3;
Type | Description |
StreamingSideInputLocation | The sideInputLocation. |
getSideInputLocationOrBuilder()
public StreamingSideInputLocationOrBuilder getSideInputLocationOrBuilder()
The stream is a streaming side input.
.google.dataflow.v1beta3.StreamingSideInputLocation side_input_location = 3;
Type | Description |
StreamingSideInputLocationOrBuilder |
getStreamingStageLocation()
public StreamingStageLocation getStreamingStageLocation()
The stream is part of another computation within the current streaming Dataflow job.
.google.dataflow.v1beta3.StreamingStageLocation streaming_stage_location = 1;
Type | Description |
StreamingStageLocation | The streamingStageLocation. |
getStreamingStageLocationOrBuilder()
public StreamingStageLocationOrBuilder getStreamingStageLocationOrBuilder()
The stream is part of another computation within the current streaming Dataflow job.
.google.dataflow.v1beta3.StreamingStageLocation streaming_stage_location = 1;
Type | Description |
StreamingStageLocationOrBuilder |
getUnknownFields()
public final UnknownFieldSet getUnknownFields()
Type | Description |
UnknownFieldSet |
hasCustomSourceLocation()
public boolean hasCustomSourceLocation()
The stream is a custom source.
.google.dataflow.v1beta3.CustomSourceLocation custom_source_location = 4;
Type | Description |
boolean | Whether the customSourceLocation field is set. |
hasPubsubLocation()
public boolean hasPubsubLocation()
The stream is a pubsub stream.
.google.dataflow.v1beta3.PubsubLocation pubsub_location = 2;
Type | Description |
boolean | Whether the pubsubLocation field is set. |
hasSideInputLocation()
public boolean hasSideInputLocation()
The stream is a streaming side input.
.google.dataflow.v1beta3.StreamingSideInputLocation side_input_location = 3;
Type | Description |
boolean | Whether the sideInputLocation field is set. |
hasStreamingStageLocation()
public boolean hasStreamingStageLocation()
The stream is part of another computation within the current streaming Dataflow job.
.google.dataflow.v1beta3.StreamingStageLocation streaming_stage_location = 1;
Type | Description |
boolean | Whether the streamingStageLocation field is set. |
hashCode()
public int hashCode()
Type | Description |
int |
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Type | Description |
FieldAccessorTable |
isInitialized()
public final boolean isInitialized()
Type | Description |
boolean |
newBuilderForType()
public StreamLocation.Builder newBuilderForType()
Type | Description |
StreamLocation.Builder |
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected StreamLocation.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Name | Description |
parent | BuilderParent |
Type | Description |
StreamLocation.Builder |
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Name | Description |
unused | UnusedPrivateParameter |
Type | Description |
Object |
toBuilder()
public StreamLocation.Builder toBuilder()
Type | Description |
StreamLocation.Builder |
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)
Name | Description |
output | CodedOutputStream |
Type | Description |
IOException |