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.IOExceptionpublic boolean hasStream()
required .heron.proto.api.StreamId stream = 1;hasStream in interface TopologyAPI.InputStreamOrBuilderpublic TopologyAPI.StreamId getStream()
required .heron.proto.api.StreamId stream = 1;getStream in interface TopologyAPI.InputStreamOrBuilderpublic 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.InputStreamOrBuilderpublic boolean hasGtype()
required .heron.proto.api.Grouping gtype = 2;hasGtype in interface TopologyAPI.InputStreamOrBuilderpublic TopologyAPI.Grouping getGtype()
required .heron.proto.api.Grouping gtype = 2;getGtype in interface TopologyAPI.InputStreamOrBuilderpublic 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.InputStreamOrBuilderpublic TopologyAPI.StreamSchema getGroupingFields()
optional .heron.proto.api.StreamSchema grouping_fields = 3;getGroupingFields in interface TopologyAPI.InputStreamOrBuilderpublic 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.InputStreamOrBuilderpublic boolean hasCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4;hasCustomGroupingJavaObject in interface TopologyAPI.InputStreamOrBuilderpublic com.google.protobuf.ByteString getCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4;getCustomGroupingJavaObject in interface TopologyAPI.InputStreamOrBuilderpublic 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;