Package org.apache.flink.fnexecution.v1
Class FlinkFnApi.TypeInfo
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo
-
- All Implemented Interfaces:
com.google.protobuf.Message,com.google.protobuf.MessageLite,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Serializable,FlinkFnApi.TypeInfoOrBuilder
- Enclosing class:
- FlinkFnApi
public static final class FlinkFnApi.TypeInfo extends com.google.protobuf.GeneratedMessageV3 implements FlinkFnApi.TypeInfoOrBuilder
A representation of the data type information in DataStream.
Protobuf typeorg.apache.flink.fn_execution.v1.TypeInfo- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classFlinkFnApi.TypeInfo.AvroTypeInfoProtobuf typeorg.apache.flink.fn_execution.v1.TypeInfo.AvroTypeInfostatic interfaceFlinkFnApi.TypeInfo.AvroTypeInfoOrBuilderstatic classFlinkFnApi.TypeInfo.BuilderA representation of the data type information in DataStream.static classFlinkFnApi.TypeInfo.MapTypeInfoProtobuf typeorg.apache.flink.fn_execution.v1.TypeInfo.MapTypeInfostatic interfaceFlinkFnApi.TypeInfo.MapTypeInfoOrBuilderstatic classFlinkFnApi.TypeInfo.RowTypeInfoProtobuf typeorg.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfostatic interfaceFlinkFnApi.TypeInfo.RowTypeInfoOrBuilderstatic classFlinkFnApi.TypeInfo.TupleTypeInfoProtobuf typeorg.apache.flink.fn_execution.v1.TypeInfo.TupleTypeInfostatic interfaceFlinkFnApi.TypeInfo.TupleTypeInfoOrBuilderstatic classFlinkFnApi.TypeInfo.TypeInfoCasestatic classFlinkFnApi.TypeInfo.TypeNameProtobuf enumorg.apache.flink.fn_execution.v1.TypeInfo.TypeName-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static intAVRO_TYPE_INFO_FIELD_NUMBERstatic intCOLLECTION_ELEMENT_TYPE_FIELD_NUMBERstatic intMAP_TYPE_INFO_FIELD_NUMBERstatic intROW_TYPE_INFO_FIELD_NUMBERstatic intTUPLE_TYPE_INFO_FIELD_NUMBERstatic intTYPE_NAME_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)FlinkFnApi.TypeInfo.AvroTypeInfogetAvroTypeInfo().org.apache.flink.fn_execution.v1.TypeInfo.AvroTypeInfo avro_type_info = 6;FlinkFnApi.TypeInfo.AvroTypeInfoOrBuildergetAvroTypeInfoOrBuilder().org.apache.flink.fn_execution.v1.TypeInfo.AvroTypeInfo avro_type_info = 6;FlinkFnApi.TypeInfogetCollectionElementType().org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2;FlinkFnApi.TypeInfoOrBuildergetCollectionElementTypeOrBuilder().org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2;static FlinkFnApi.TypeInfogetDefaultInstance()FlinkFnApi.TypeInfogetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()FlinkFnApi.TypeInfo.MapTypeInfogetMapTypeInfo().org.apache.flink.fn_execution.v1.TypeInfo.MapTypeInfo map_type_info = 5;FlinkFnApi.TypeInfo.MapTypeInfoOrBuildergetMapTypeInfoOrBuilder().org.apache.flink.fn_execution.v1.TypeInfo.MapTypeInfo map_type_info = 5;com.google.protobuf.Parser<FlinkFnApi.TypeInfo>getParserForType()FlinkFnApi.TypeInfo.RowTypeInfogetRowTypeInfo().org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo row_type_info = 3;FlinkFnApi.TypeInfo.RowTypeInfoOrBuildergetRowTypeInfoOrBuilder().org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo row_type_info = 3;intgetSerializedSize()FlinkFnApi.TypeInfo.TupleTypeInfogetTupleTypeInfo().org.apache.flink.fn_execution.v1.TypeInfo.TupleTypeInfo tuple_type_info = 4;FlinkFnApi.TypeInfo.TupleTypeInfoOrBuildergetTupleTypeInfoOrBuilder().org.apache.flink.fn_execution.v1.TypeInfo.TupleTypeInfo tuple_type_info = 4;FlinkFnApi.TypeInfo.TypeInfoCasegetTypeInfoCase()FlinkFnApi.TypeInfo.TypeNamegetTypeName().org.apache.flink.fn_execution.v1.TypeInfo.TypeName type_name = 1;intgetTypeNameValue().org.apache.flink.fn_execution.v1.TypeInfo.TypeName type_name = 1;com.google.protobuf.UnknownFieldSetgetUnknownFields()booleanhasAvroTypeInfo().org.apache.flink.fn_execution.v1.TypeInfo.AvroTypeInfo avro_type_info = 6;booleanhasCollectionElementType().org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2;inthashCode()booleanhasMapTypeInfo().org.apache.flink.fn_execution.v1.TypeInfo.MapTypeInfo map_type_info = 5;booleanhasRowTypeInfo().org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo row_type_info = 3;booleanhasTupleTypeInfo().org.apache.flink.fn_execution.v1.TypeInfo.TupleTypeInfo tuple_type_info = 4;protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()static FlinkFnApi.TypeInfo.BuildernewBuilder()static FlinkFnApi.TypeInfo.BuildernewBuilder(FlinkFnApi.TypeInfo prototype)FlinkFnApi.TypeInfo.BuildernewBuilderForType()protected FlinkFnApi.TypeInfo.BuildernewBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)protected ObjectnewInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)static FlinkFnApi.TypeInfoparseDelimitedFrom(InputStream input)static FlinkFnApi.TypeInfoparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlinkFnApi.TypeInfoparseFrom(byte[] data)static FlinkFnApi.TypeInfoparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlinkFnApi.TypeInfoparseFrom(com.google.protobuf.ByteString data)static FlinkFnApi.TypeInfoparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlinkFnApi.TypeInfoparseFrom(com.google.protobuf.CodedInputStream input)static FlinkFnApi.TypeInfoparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlinkFnApi.TypeInfoparseFrom(InputStream input)static FlinkFnApi.TypeInfoparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlinkFnApi.TypeInfoparseFrom(ByteBuffer data)static FlinkFnApi.TypeInfoparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<FlinkFnApi.TypeInfo>parser()FlinkFnApi.TypeInfo.BuildertoBuilder()voidwriteTo(com.google.protobuf.CodedOutputStream output)-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
TYPE_NAME_FIELD_NUMBER
public static final int TYPE_NAME_FIELD_NUMBER
- See Also:
- Constant Field Values
-
COLLECTION_ELEMENT_TYPE_FIELD_NUMBER
public static final int COLLECTION_ELEMENT_TYPE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ROW_TYPE_INFO_FIELD_NUMBER
public static final int ROW_TYPE_INFO_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TUPLE_TYPE_INFO_FIELD_NUMBER
public static final int TUPLE_TYPE_INFO_FIELD_NUMBER
- See Also:
- Constant Field Values
-
MAP_TYPE_INFO_FIELD_NUMBER
public static final int MAP_TYPE_INFO_FIELD_NUMBER
- See Also:
- Constant Field Values
-
AVRO_TYPE_INFO_FIELD_NUMBER
public static final int AVRO_TYPE_INFO_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstancein classcom.google.protobuf.GeneratedMessageV3
-
getUnknownFields
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
- Specified by:
getUnknownFieldsin interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3
-
getTypeInfoCase
public FlinkFnApi.TypeInfo.TypeInfoCase getTypeInfoCase()
- Specified by:
getTypeInfoCasein interfaceFlinkFnApi.TypeInfoOrBuilder
-
getTypeNameValue
public int getTypeNameValue()
.org.apache.flink.fn_execution.v1.TypeInfo.TypeName type_name = 1;- Specified by:
getTypeNameValuein interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- The enum numeric value on the wire for typeName.
-
getTypeName
public FlinkFnApi.TypeInfo.TypeName getTypeName()
.org.apache.flink.fn_execution.v1.TypeInfo.TypeName type_name = 1;- Specified by:
getTypeNamein interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- The typeName.
-
hasCollectionElementType
public boolean hasCollectionElementType()
.org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2;- Specified by:
hasCollectionElementTypein interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- Whether the collectionElementType field is set.
-
getCollectionElementType
public FlinkFnApi.TypeInfo getCollectionElementType()
.org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2;- Specified by:
getCollectionElementTypein interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- The collectionElementType.
-
getCollectionElementTypeOrBuilder
public FlinkFnApi.TypeInfoOrBuilder getCollectionElementTypeOrBuilder()
.org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2;- Specified by:
getCollectionElementTypeOrBuilderin interfaceFlinkFnApi.TypeInfoOrBuilder
-
hasRowTypeInfo
public boolean hasRowTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo row_type_info = 3;- Specified by:
hasRowTypeInfoin interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- Whether the rowTypeInfo field is set.
-
getRowTypeInfo
public FlinkFnApi.TypeInfo.RowTypeInfo getRowTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo row_type_info = 3;- Specified by:
getRowTypeInfoin interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- The rowTypeInfo.
-
getRowTypeInfoOrBuilder
public FlinkFnApi.TypeInfo.RowTypeInfoOrBuilder getRowTypeInfoOrBuilder()
.org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo row_type_info = 3;- Specified by:
getRowTypeInfoOrBuilderin interfaceFlinkFnApi.TypeInfoOrBuilder
-
hasTupleTypeInfo
public boolean hasTupleTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo.TupleTypeInfo tuple_type_info = 4;- Specified by:
hasTupleTypeInfoin interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- Whether the tupleTypeInfo field is set.
-
getTupleTypeInfo
public FlinkFnApi.TypeInfo.TupleTypeInfo getTupleTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo.TupleTypeInfo tuple_type_info = 4;- Specified by:
getTupleTypeInfoin interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- The tupleTypeInfo.
-
getTupleTypeInfoOrBuilder
public FlinkFnApi.TypeInfo.TupleTypeInfoOrBuilder getTupleTypeInfoOrBuilder()
.org.apache.flink.fn_execution.v1.TypeInfo.TupleTypeInfo tuple_type_info = 4;- Specified by:
getTupleTypeInfoOrBuilderin interfaceFlinkFnApi.TypeInfoOrBuilder
-
hasMapTypeInfo
public boolean hasMapTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo.MapTypeInfo map_type_info = 5;- Specified by:
hasMapTypeInfoin interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- Whether the mapTypeInfo field is set.
-
getMapTypeInfo
public FlinkFnApi.TypeInfo.MapTypeInfo getMapTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo.MapTypeInfo map_type_info = 5;- Specified by:
getMapTypeInfoin interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- The mapTypeInfo.
-
getMapTypeInfoOrBuilder
public FlinkFnApi.TypeInfo.MapTypeInfoOrBuilder getMapTypeInfoOrBuilder()
.org.apache.flink.fn_execution.v1.TypeInfo.MapTypeInfo map_type_info = 5;- Specified by:
getMapTypeInfoOrBuilderin interfaceFlinkFnApi.TypeInfoOrBuilder
-
hasAvroTypeInfo
public boolean hasAvroTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo.AvroTypeInfo avro_type_info = 6;- Specified by:
hasAvroTypeInfoin interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- Whether the avroTypeInfo field is set.
-
getAvroTypeInfo
public FlinkFnApi.TypeInfo.AvroTypeInfo getAvroTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo.AvroTypeInfo avro_type_info = 6;- Specified by:
getAvroTypeInfoin interfaceFlinkFnApi.TypeInfoOrBuilder- Returns:
- The avroTypeInfo.
-
getAvroTypeInfoOrBuilder
public FlinkFnApi.TypeInfo.AvroTypeInfoOrBuilder getAvroTypeInfoOrBuilder()
.org.apache.flink.fn_execution.v1.TypeInfo.AvroTypeInfo avro_type_info = 6;- Specified by:
getAvroTypeInfoOrBuilderin interfaceFlinkFnApi.TypeInfoOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessageV3- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.google.protobuf.AbstractMessage
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static FlinkFnApi.TypeInfo parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static FlinkFnApi.TypeInfo parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static FlinkFnApi.TypeInfo parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public FlinkFnApi.TypeInfo.Builder newBuilderForType()
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
public static FlinkFnApi.TypeInfo.Builder newBuilder()
-
newBuilder
public static FlinkFnApi.TypeInfo.Builder newBuilder(FlinkFnApi.TypeInfo prototype)
-
toBuilder
public FlinkFnApi.TypeInfo.Builder toBuilder()
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected FlinkFnApi.TypeInfo.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static FlinkFnApi.TypeInfo getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<FlinkFnApi.TypeInfo> parser()
-
getParserForType
public com.google.protobuf.Parser<FlinkFnApi.TypeInfo> getParserForType()
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public FlinkFnApi.TypeInfo getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-