public static interface TopologyAPI.InputStreamOrBuilder
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.ByteString |
getCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4; |
TopologyAPI.StreamSchema |
getGroupingFields()
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.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; |
boolean hasStream()
required .heron.proto.api.StreamId stream = 1;
TopologyAPI.StreamId getStream()
required .heron.proto.api.StreamId stream = 1;
TopologyAPI.StreamIdOrBuilder getStreamOrBuilder()
required .heron.proto.api.StreamId stream = 1;
boolean hasGtype()
required .heron.proto.api.Grouping gtype = 2;
TopologyAPI.Grouping getGtype()
required .heron.proto.api.Grouping gtype = 2;
boolean hasGroupingFields()
optional .heron.proto.api.StreamSchema grouping_fields = 3;
TopologyAPI.StreamSchema getGroupingFields()
optional .heron.proto.api.StreamSchema grouping_fields = 3;
TopologyAPI.StreamSchemaOrBuilder getGroupingFieldsOrBuilder()
optional .heron.proto.api.StreamSchema grouping_fields = 3;
boolean hasCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4;
com.google.protobuf.ByteString getCustomGroupingJavaObject()
optional bytes custom_grouping_java_object = 4;