public static final class TopologyAPI.InputStream.Builder extendsimplements TopologyAPI.InputStreamOrBuilder
heron.proto.api.InputStream
Modifier and Type | Method and Description |
---|---|
TopologyAPI.InputStream |
build() |
TopologyAPI.InputStream |
buildPartial() |
TopologyAPI.InputStream.Builder |
clear() |
TopologyAPI.InputStream.Builder |
clearCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4; |
TopologyAPI.InputStream.Builder |
clearGroupingFields()
optional .heron.proto.api.StreamSchema grouping_fields = 3; |
TopologyAPI.InputStream.Builder |
clearGtype()
required .heron.proto.api.Grouping gtype = 2; |
TopologyAPI.InputStream.Builder |
clearStream()
required .heron.proto.api.StreamId stream = 1; |
TopologyAPI.InputStream.Builder |
clone() |
com.google.protobuf.ByteString |
getCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4; |
TopologyAPI.InputStream |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.Descriptors.Descriptor |
getDescriptorForType() |
TopologyAPI.StreamSchema |
getGroupingFields()
optional .heron.proto.api.StreamSchema grouping_fields = 3; |
TopologyAPI.StreamSchema.Builder |
getGroupingFieldsBuilder()
optional .heron.proto.api.StreamSchema grouping_fields = 3; |
TopologyAPI.StreamSchemaOrBuilder |
getGroupingFieldsOrBuilder()
optional .heron.proto.api.StreamSchema grouping_fields = 3; |
TopologyAPI.Grouping |
getGtype()
required .heron.proto.api.Grouping gtype = 2; |
TopologyAPI.StreamId |
getStream()
required .heron.proto.api.StreamId stream = 1; |
TopologyAPI.StreamId.Builder |
getStreamBuilder()
required .heron.proto.api.StreamId stream = 1; |
TopologyAPI.StreamIdOrBuilder |
getStreamOrBuilder()
required .heron.proto.api.StreamId stream = 1; |
boolean |
hasCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4; |
boolean |
hasGroupingFields()
optional .heron.proto.api.StreamSchema grouping_fields = 3; |
boolean |
hasGtype()
required .heron.proto.api.Grouping gtype = 2; |
boolean |
hasStream()
required .heron.proto.api.StreamId stream = 1; |
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
TopologyAPI.InputStream.Builder |
mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
TopologyAPI.InputStream.Builder |
mergeFrom(com.google.protobuf.Message other) |
TopologyAPI.InputStream.Builder |
mergeGroupingFields(TopologyAPI.StreamSchema value)
optional .heron.proto.api.StreamSchema grouping_fields = 3; |
TopologyAPI.InputStream.Builder |
mergeStream(TopologyAPI.StreamId value)
required .heron.proto.api.StreamId stream = 1; |
TopologyAPI.InputStream.Builder |
setCustomGroupingJavaObject(com.google.protobuf.ByteString value)
optional bytes custom_grouping_java_object = 4; |
TopologyAPI.InputStream.Builder |
setGroupingFields(TopologyAPI.StreamSchema.Builder builderForValue)
optional .heron.proto.api.StreamSchema grouping_fields = 3; |
TopologyAPI.InputStream.Builder |
setGroupingFields(TopologyAPI.StreamSchema value)
optional .heron.proto.api.StreamSchema grouping_fields = 3; |
TopologyAPI.InputStream.Builder |
setGtype(TopologyAPI.Grouping value)
required .heron.proto.api.Grouping gtype = 2; |
TopologyAPI.InputStream.Builder |
setStream(TopologyAPI.StreamId.Builder builderForValue)
required .heron.proto.api.StreamId stream = 1; |
TopologyAPI.InputStream.Builder |
setStream(TopologyAPI.StreamId value)
required .heron.proto.api.StreamId stream = 1; |
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
public TopologyAPI.InputStream.Builder clear()
public TopologyAPI.InputStream.Builder clone()
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
public TopologyAPI.InputStream getDefaultInstanceForType()
public TopologyAPI.InputStream build()
public TopologyAPI.InputStream buildPartial()
public TopologyAPI.InputStream.Builder mergeFrom(com.google.protobuf.Message other)
public final boolean isInitialized()
public TopologyAPI.InputStream.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public boolean hasStream()
required .heron.proto.api.StreamId stream = 1;
hasStream
in interface TopologyAPI.InputStreamOrBuilder
public TopologyAPI.StreamId getStream()
required .heron.proto.api.StreamId stream = 1;
getStream
in interface TopologyAPI.InputStreamOrBuilder
public TopologyAPI.InputStream.Builder setStream(TopologyAPI.StreamId value)
required .heron.proto.api.StreamId stream = 1;
public TopologyAPI.InputStream.Builder setStream(TopologyAPI.StreamId.Builder builderForValue)
required .heron.proto.api.StreamId stream = 1;
public TopologyAPI.InputStream.Builder mergeStream(TopologyAPI.StreamId value)
required .heron.proto.api.StreamId stream = 1;
public TopologyAPI.InputStream.Builder clearStream()
required .heron.proto.api.StreamId stream = 1;
public TopologyAPI.StreamId.Builder getStreamBuilder()
required .heron.proto.api.StreamId stream = 1;
public TopologyAPI.StreamIdOrBuilder getStreamOrBuilder()
required .heron.proto.api.StreamId stream = 1;
getStreamOrBuilder
in interface TopologyAPI.InputStreamOrBuilder
public boolean hasGtype()
required .heron.proto.api.Grouping gtype = 2;
hasGtype
in interface TopologyAPI.InputStreamOrBuilder
public TopologyAPI.Grouping getGtype()
required .heron.proto.api.Grouping gtype = 2;
getGtype
in interface TopologyAPI.InputStreamOrBuilder
public TopologyAPI.InputStream.Builder setGtype(TopologyAPI.Grouping value)
required .heron.proto.api.Grouping gtype = 2;
public TopologyAPI.InputStream.Builder clearGtype()
required .heron.proto.api.Grouping gtype = 2;
public boolean hasGroupingFields()
optional .heron.proto.api.StreamSchema grouping_fields = 3;
hasGroupingFields
in interface TopologyAPI.InputStreamOrBuilder
public TopologyAPI.StreamSchema getGroupingFields()
optional .heron.proto.api.StreamSchema grouping_fields = 3;
getGroupingFields
in interface TopologyAPI.InputStreamOrBuilder
public TopologyAPI.InputStream.Builder setGroupingFields(TopologyAPI.StreamSchema value)
optional .heron.proto.api.StreamSchema grouping_fields = 3;
public TopologyAPI.InputStream.Builder setGroupingFields(TopologyAPI.StreamSchema.Builder builderForValue)
optional .heron.proto.api.StreamSchema grouping_fields = 3;
public TopologyAPI.InputStream.Builder mergeGroupingFields(TopologyAPI.StreamSchema value)
optional .heron.proto.api.StreamSchema grouping_fields = 3;
public TopologyAPI.InputStream.Builder clearGroupingFields()
optional .heron.proto.api.StreamSchema grouping_fields = 3;
public TopologyAPI.StreamSchema.Builder getGroupingFieldsBuilder()
optional .heron.proto.api.StreamSchema grouping_fields = 3;
public TopologyAPI.StreamSchemaOrBuilder getGroupingFieldsOrBuilder()
optional .heron.proto.api.StreamSchema grouping_fields = 3;
getGroupingFieldsOrBuilder
in interface TopologyAPI.InputStreamOrBuilder
public boolean hasCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4;
hasCustomGroupingJavaObject
in interface TopologyAPI.InputStreamOrBuilder
public com.google.protobuf.ByteString getCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4;
getCustomGroupingJavaObject
in interface TopologyAPI.InputStreamOrBuilder
public TopologyAPI.InputStream.Builder setCustomGroupingJavaObject(com.google.protobuf.ByteString value)
optional bytes custom_grouping_java_object = 4;
public TopologyAPI.InputStream.Builder clearCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4;