com.twitter.heron.api.generated

Class TopologyAPI.InputStream

java.lang.Object

com.google.protobuf.GeneratedMessage

com.twitter.heron.api.generated.TopologyAPI.InputStream

All Implemented Interfaces:

TopologyAPI.InputStreamOrBuilder

Enclosing class:

TopologyAPI

public static final class TopologyAPI.InputStream
extends com.google.protobuf.GeneratedMessage
implements TopologyAPI.InputStreamOrBuilder

Protobuf type heron.proto.api.InputStream

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TopologyAPI.InputStream.Builder Protobuf type heron.proto.api.InputStream

Field Summary

Fields

Modifier and Type	Field and Description
static int	CUSTOM_GROUPING_JAVA_OBJECT_FIELD_NUMBER
static int	GROUPING_FIELDS_FIELD_NUMBER
static int	GTYPE_FIELD_NUMBER
static	PARSER
static int	STREAM_FIELD_NUMBER

Method Summary

Methods

Modifier and Type	Method and Description
com.google.protobuf.ByteString	getCustomGroupingJavaObject() optional bytes custom_grouping_java_object = 4;
static TopologyAPI.InputStream	getDefaultInstance()
TopologyAPI.InputStream	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
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;
	getParserForType()
int	getSerializedSize()
TopologyAPI.StreamId	getStream() required .heron.proto.api.StreamId stream = 1;
TopologyAPI.StreamIdOrBuilder	getStreamOrBuilder() required .heron.proto.api.StreamId stream = 1;
com.google.protobuf.UnknownFieldSet	getUnknownFields()
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()
static TopologyAPI.InputStream.Builder	newBuilder()
static TopologyAPI.InputStream.Builder	newBuilder(TopologyAPI.InputStream prototype)
TopologyAPI.InputStream.Builder	newBuilderForType()
protected TopologyAPI.InputStream.Builder	newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent)
static TopologyAPI.InputStream	parseDelimitedFrom(java.io.InputStream input)
static TopologyAPI.InputStream	parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static TopologyAPI.InputStream	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static TopologyAPI.InputStream	parseFrom(com.google.protobuf.ByteString data)
static TopologyAPI.InputStream	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static TopologyAPI.InputStream	parseFrom(com.google.protobuf.CodedInputStream input)
static TopologyAPI.InputStream	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static TopologyAPI.InputStream	parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
TopologyAPI.InputStream.Builder	toBuilder()
protected java.lang.Object	writeReplace()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PARSER

public static  PARSER

STREAM_FIELD_NUMBER

public static final int STREAM_FIELD_NUMBER

See Also:

Constant Field Values

GTYPE_FIELD_NUMBER

public static final int GTYPE_FIELD_NUMBER

See Also:

Constant Field Values

GROUPING_FIELDS_FIELD_NUMBER

public static final int GROUPING_FIELDS_FIELD_NUMBER

See Also:

Constant Field Values

CUSTOM_GROUPING_JAVA_OBJECT_FIELD_NUMBER

public static final int CUSTOM_GROUPING_JAVA_OBJECT_FIELD_NUMBER

See Also:

Constant Field Values

Method Detail

getDefaultInstance

public static TopologyAPI.InputStream getDefaultInstance()

getDefaultInstanceForType

public TopologyAPI.InputStream getDefaultInstanceForType()

getUnknownFields

public final com.google.protobuf.UnknownFieldSet getUnknownFields()

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

internalGetFieldAccessorTable

protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()

getParserForType

public  getParserForType()

hasStream

public boolean hasStream()

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

Specified by:

hasStream in interface TopologyAPI.InputStreamOrBuilder

getStream

public TopologyAPI.StreamId getStream()

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

Specified by:

getStream in interface TopologyAPI.InputStreamOrBuilder

getStreamOrBuilder

public TopologyAPI.StreamIdOrBuilder getStreamOrBuilder()

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

Specified by:

getStreamOrBuilder in interface TopologyAPI.InputStreamOrBuilder

hasGtype

public boolean hasGtype()

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

Specified by:

hasGtype in interface TopologyAPI.InputStreamOrBuilder

getGtype

public TopologyAPI.Grouping getGtype()

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

Specified by:

getGtype in interface TopologyAPI.InputStreamOrBuilder

hasGroupingFields

public boolean hasGroupingFields()

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

Specified by:

hasGroupingFields in interface TopologyAPI.InputStreamOrBuilder

getGroupingFields

public TopologyAPI.StreamSchema getGroupingFields()

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

Specified by:

getGroupingFields in interface TopologyAPI.InputStreamOrBuilder

getGroupingFieldsOrBuilder

public TopologyAPI.StreamSchemaOrBuilder getGroupingFieldsOrBuilder()

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

Specified by:

getGroupingFieldsOrBuilder in interface TopologyAPI.InputStreamOrBuilder

hasCustomGroupingJavaObject

public boolean hasCustomGroupingJavaObject()

optional bytes custom_grouping_java_object = 4;

Specified by:

hasCustomGroupingJavaObject in interface TopologyAPI.InputStreamOrBuilder

getCustomGroupingJavaObject

public com.google.protobuf.ByteString getCustomGroupingJavaObject()

optional bytes custom_grouping_java_object = 4;

Specified by:

getCustomGroupingJavaObject in interface TopologyAPI.InputStreamOrBuilder

isInitialized

public final boolean isInitialized()

writeTo

public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws java.io.IOException

Throws:

java.io.IOException

getSerializedSize

public int getSerializedSize()

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

parseFrom

public static TopologyAPI.InputStream parseFrom(com.google.protobuf.ByteString data)
                                         throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static TopologyAPI.InputStream parseFrom(com.google.protobuf.ByteString data,
                                com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                         throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static TopologyAPI.InputStream parseFrom(byte[] data,
                                com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                         throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static TopologyAPI.InputStream parseFrom(java.io.InputStream input,
                                com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                         throws java.io.IOException

Throws:

java.io.IOException

parseDelimitedFrom

public static TopologyAPI.InputStream parseDelimitedFrom(java.io.InputStream input)
                                                  throws java.io.IOException

Throws:

java.io.IOException

parseDelimitedFrom

public static TopologyAPI.InputStream parseDelimitedFrom(java.io.InputStream input,
                                         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                  throws java.io.IOException

Throws:

java.io.IOException

parseFrom

public static TopologyAPI.InputStream parseFrom(com.google.protobuf.CodedInputStream input)
                                         throws java.io.IOException

Throws:

java.io.IOException

parseFrom

public static TopologyAPI.InputStream parseFrom(com.google.protobuf.CodedInputStream input,
                                com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                         throws java.io.IOException

Throws:

java.io.IOException

newBuilder

public static TopologyAPI.InputStream.Builder newBuilder()

newBuilderForType

public TopologyAPI.InputStream.Builder newBuilderForType()

newBuilder

public static TopologyAPI.InputStream.Builder newBuilder(TopologyAPI.InputStream prototype)

toBuilder

public TopologyAPI.InputStream.Builder toBuilder()

newBuilderForType

protected TopologyAPI.InputStream.Builder newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent)