com.twitter.heron.api.generated

Interface TopologyAPI.InputStreamOrBuilder

All Known Implementing Classes:

TopologyAPI.InputStream, TopologyAPI.InputStream.Builder

Enclosing class:

TopologyAPI

public static interface TopologyAPI.InputStreamOrBuilder

Method Summary

Methods

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;

Method Detail

hasStream

boolean hasStream()

required .heron.proto.api.StreamId stream = 1;

getStream

TopologyAPI.StreamId getStream()

required .heron.proto.api.StreamId stream = 1;

getStreamOrBuilder

TopologyAPI.StreamIdOrBuilder getStreamOrBuilder()

required .heron.proto.api.StreamId stream = 1;

hasGtype

boolean hasGtype()

required .heron.proto.api.Grouping gtype = 2;

getGtype

TopologyAPI.Grouping getGtype()

required .heron.proto.api.Grouping gtype = 2;

hasGroupingFields

boolean hasGroupingFields()

optional .heron.proto.api.StreamSchema grouping_fields = 3;

getGroupingFields

TopologyAPI.StreamSchema getGroupingFields()

optional .heron.proto.api.StreamSchema grouping_fields = 3;

getGroupingFieldsOrBuilder

TopologyAPI.StreamSchemaOrBuilder getGroupingFieldsOrBuilder()

optional .heron.proto.api.StreamSchema grouping_fields = 3;

hasCustomGroupingJavaObject

boolean hasCustomGroupingJavaObject()

optional bytes custom_grouping_java_object = 4;

getCustomGroupingJavaObject

com.google.protobuf.ByteString getCustomGroupingJavaObject()

optional bytes custom_grouping_java_object = 4;