Index (Flink : Formats : Protobuf 1.19.2-cp2 API)

A B C D E F G H I M N O P R S U V W
All Classes All Packages

A

appendLine(String) - Method in class org.apache.flink.formats.protobuf.util.PbCodegenAppender
appendSegment(String) - Method in class org.apache.flink.formats.protobuf.util.PbCodegenAppender

B

begin() - Method in class org.apache.flink.formats.protobuf.util.PbCodegenAppender
begin(String) - Method in class org.apache.flink.formats.protobuf.util.PbCodegenAppender
build() - Method in class org.apache.flink.formats.protobuf.PbFormatConfig.PbFormatConfigBuilder

C

code() - Method in class org.apache.flink.formats.protobuf.util.PbCodegenAppender
codegen(String, String, int) - Method in class org.apache.flink.formats.protobuf.deserialize.PbCodegenArrayDeserializer
codegen(String, String, int) - Method in interface org.apache.flink.formats.protobuf.deserialize.PbCodegenDeserializer
codegen(String, String, int) - Method in class org.apache.flink.formats.protobuf.deserialize.PbCodegenMapDeserializer
codegen(String, String, int) - Method in class org.apache.flink.formats.protobuf.deserialize.PbCodegenRowDeserializer
codegen(String, String, int) - Method in class org.apache.flink.formats.protobuf.deserialize.PbCodegenSimpleDeserializer
codegen(String, String, int) - Method in class org.apache.flink.formats.protobuf.serialize.PbCodegenArraySerializer
codegen(String, String, int) - Method in class org.apache.flink.formats.protobuf.serialize.PbCodegenMapSerializer
codegen(String, String, int) - Method in class org.apache.flink.formats.protobuf.serialize.PbCodegenRowSerializer
codegen(String, String, int) - Method in interface org.apache.flink.formats.protobuf.serialize.PbCodegenSerializer
codegen(String, String, int) - Method in class org.apache.flink.formats.protobuf.serialize.PbCodegenSimpleSerializer
CODEGEN_SPLIT_THRESHOLD - Static variable in class org.apache.flink.formats.protobuf.PbConstant: JIT optimizer threshold is 8K, unicode encode one char use 1byte, so use 4K as codegen_spilt_threshold，A conservative threshold is selected to prevent multiple element code segments in RowType from being combined to exceed 8K.
com.google.protobuf - package com.google.protobuf
compileClass(ClassLoader, String, String) - Static method in class org.apache.flink.formats.protobuf.util.PbCodegenUtils
convertFlinkArrayElementToPbWithDefaultValueCode(String, String, String, Descriptors.FieldDescriptor, LogicalType, PbFormatContext, int) - Static method in class org.apache.flink.formats.protobuf.util.PbCodegenUtils: This method will be called from serializer of flink array/map type because flink contains both array/map type in array format.
convertProtoBinaryToRow(byte[]) - Method in class org.apache.flink.formats.protobuf.deserialize.ProtoToRowConverter
convertRowToProtoBinary(RowData) - Method in class org.apache.flink.formats.protobuf.serialize.RowToProtoConverter
createDecodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.protobuf.PbFileFormatFactory
createDecodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.protobuf.PbFormatFactory
createEncodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.protobuf.PbFileFormatFactory
createEncodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.protobuf.PbFormatFactory
createRuntimeDecoder(DynamicTableSource.Context, DataType) - Method in class org.apache.flink.formats.protobuf.PbDecodingFormat
createRuntimeEncoder(DynamicTableSink.Context, DataType) - Method in class org.apache.flink.formats.protobuf.PbEncodingFormat
currentIndent() - Method in class org.apache.flink.formats.protobuf.util.PbCodegenAppender

D

deserialize(byte[]) - Method in class org.apache.flink.formats.protobuf.deserialize.PbRowDataDeserializationSchema

E

end() - Method in class org.apache.flink.formats.protobuf.util.PbCodegenAppender
end(String) - Method in class org.apache.flink.formats.protobuf.util.PbCodegenAppender
equals(Object) - Method in class org.apache.flink.formats.protobuf.deserialize.PbRowDataDeserializationSchema
equals(Object) - Method in class org.apache.flink.formats.protobuf.PbFormatConfig

F

factoryIdentifier() - Method in class org.apache.flink.formats.protobuf.PbFileFormatFactory
factoryIdentifier() - Method in class org.apache.flink.formats.protobuf.PbFormatFactory
flinkContainerElementCode(String, String, LogicalType) - Static method in class org.apache.flink.formats.protobuf.util.PbCodegenUtils
forwardOptions() - Method in class org.apache.flink.formats.protobuf.PbFileFormatFactory

G

GENERATED_DECODE_METHOD - Static variable in class org.apache.flink.formats.protobuf.PbConstant
GENERATED_ENCODE_METHOD - Static variable in class org.apache.flink.formats.protobuf.PbConstant
generateRowType(Descriptors.Descriptor) - Static method in class org.apache.flink.formats.protobuf.util.PbToRowTypeUtil
generateRowType(Descriptors.Descriptor, boolean) - Static method in class org.apache.flink.formats.protobuf.util.PbToRowTypeUtil
getAndIncrement() - Method in class org.apache.flink.formats.protobuf.util.PbCodegenVarId
getChangelogMode() - Method in class org.apache.flink.formats.protobuf.PbDecodingFormat
getChangelogMode() - Method in class org.apache.flink.formats.protobuf.PbEncodingFormat
getDescriptor(String) - Static method in class org.apache.flink.formats.protobuf.util.PbFormatUtils
getFullJavaName(Descriptors.Descriptor) - Static method in class org.apache.flink.formats.protobuf.util.PbFormatUtils
getFullJavaName(Descriptors.EnumDescriptor) - Static method in class org.apache.flink.formats.protobuf.util.PbFormatUtils
getInstance() - Static method in class org.apache.flink.formats.protobuf.util.PbCodegenVarId
getMessageClassName() - Method in class org.apache.flink.formats.protobuf.PbFormatConfig
getOuterClassName(Descriptors.FileDescriptor) - Static method in class org.apache.flink.formats.protobuf.util.PbFormatUtils
getOuterProtoPrefix(Descriptors.FileDescriptor) - Static method in class org.apache.flink.formats.protobuf.util.PbFormatUtils
getPbCodegenDes(Descriptors.FieldDescriptor, LogicalType, PbFormatContext) - Static method in class org.apache.flink.formats.protobuf.deserialize.PbCodegenDeserializeFactory
getPbCodegenSer(Descriptors.FieldDescriptor, LogicalType, PbFormatContext) - Static method in class org.apache.flink.formats.protobuf.serialize.PbCodegenSerializeFactory
getPbCodegenTopRowDes(Descriptors.Descriptor, RowType, PbFormatContext) - Static method in class org.apache.flink.formats.protobuf.deserialize.PbCodegenDeserializeFactory
getPbCodegenTopRowSer(Descriptors.Descriptor, RowType, PbFormatContext) - Static method in class org.apache.flink.formats.protobuf.serialize.PbCodegenSerializeFactory
getPbFormatConfig() - Method in class org.apache.flink.formats.protobuf.PbFormatContext
getProducedType() - Method in class org.apache.flink.formats.protobuf.deserialize.PbRowDataDeserializationSchema
getSplitMethodStack() - Method in class org.apache.flink.formats.protobuf.PbFormatContext
getStrongCamelCaseJsonName(String) - Static method in class org.apache.flink.formats.protobuf.util.PbFormatUtils
getTypeStrFromLogicType(LogicalType) - Static method in class org.apache.flink.formats.protobuf.util.PbCodegenUtils: Get java type str from LogicalType which directly fetched from flink type.
getTypeStrFromProto(Descriptors.FieldDescriptor, boolean) - Static method in class org.apache.flink.formats.protobuf.util.PbCodegenUtils: Get java type str from Descriptors.FieldDescriptor which directly fetched from protobuf object.
getWriteNullStringLiterals() - Method in class org.apache.flink.formats.protobuf.PbFormatConfig

H

hashCode() - Method in class org.apache.flink.formats.protobuf.deserialize.PbRowDataDeserializationSchema
hashCode() - Method in class org.apache.flink.formats.protobuf.PbFormatConfig

I

IDENTIFIER - Static variable in class org.apache.flink.formats.protobuf.PbFormatFactory
IGNORE_PARSE_ERRORS - Static variable in class org.apache.flink.formats.protobuf.PbFormatOptions
ignoreParseErrors(boolean) - Method in class org.apache.flink.formats.protobuf.PbFormatConfig.PbFormatConfigBuilder
isArrayType(LogicalType) - Static method in class org.apache.flink.formats.protobuf.util.PbFormatUtils
isCodeSplit() - Method in class org.apache.flink.formats.protobuf.deserialize.PbRowDataDeserializationSchema
isCodeSplit() - Method in class org.apache.flink.formats.protobuf.deserialize.ProtoToRowConverter
isCodeSplit() - Method in class org.apache.flink.formats.protobuf.serialize.PbRowDataSerializationSchema
isCodeSplit() - Method in class org.apache.flink.formats.protobuf.serialize.RowToProtoConverter
isEndOfStream(RowData) - Method in class org.apache.flink.formats.protobuf.deserialize.PbRowDataDeserializationSchema
isIgnoreParseErrors() - Method in class org.apache.flink.formats.protobuf.PbFormatConfig
isReadDefaultValues() - Method in class org.apache.flink.formats.protobuf.PbFormatConfig
isRepeatedType(LogicalType) - Static method in class org.apache.flink.formats.protobuf.util.PbFormatUtils
isSimpleType(LogicalType) - Static method in class org.apache.flink.formats.protobuf.util.PbFormatUtils

M

MESSAGE_CLASS_NAME - Static variable in class org.apache.flink.formats.protobuf.PbFormatOptions
messageClassName(String) - Method in class org.apache.flink.formats.protobuf.PbFormatConfig.PbFormatConfigBuilder

N

needToSplit(int) - Static method in class org.apache.flink.formats.protobuf.util.PbCodegenUtils

O

open(DeserializationSchema.InitializationContext) - Method in class org.apache.flink.formats.protobuf.deserialize.PbRowDataDeserializationSchema
open(SerializationSchema.InitializationContext) - Method in class org.apache.flink.formats.protobuf.serialize.PbRowDataSerializationSchema
optionalOptions() - Method in class org.apache.flink.formats.protobuf.PbFileFormatFactory
optionalOptions() - Method in class org.apache.flink.formats.protobuf.PbFormatFactory
org.apache.flink.formats.protobuf - package org.apache.flink.formats.protobuf
org.apache.flink.formats.protobuf.deserialize - package org.apache.flink.formats.protobuf.deserialize
org.apache.flink.formats.protobuf.serialize - package org.apache.flink.formats.protobuf.serialize
org.apache.flink.formats.protobuf.util - package org.apache.flink.formats.protobuf.util

P

PB_MAP_KEY_NAME - Static variable in class org.apache.flink.formats.protobuf.PbConstant
PB_MAP_VALUE_NAME - Static variable in class org.apache.flink.formats.protobuf.PbConstant
PB_METHOD_GET_DESCRIPTOR - Static variable in class org.apache.flink.formats.protobuf.PbConstant
PB_METHOD_PARSE_FROM - Static variable in class org.apache.flink.formats.protobuf.PbConstant
PB_OUTER_CLASS_SUFFIX - Static variable in class org.apache.flink.formats.protobuf.PbConstant
PbCodegenAppender - Class in org.apache.flink.formats.protobuf.util: Helper class which do code fragment concat.
PbCodegenAppender() - Constructor for class org.apache.flink.formats.protobuf.util.PbCodegenAppender
PbCodegenAppender(int) - Constructor for class org.apache.flink.formats.protobuf.util.PbCodegenAppender
PbCodegenArrayDeserializer - Class in org.apache.flink.formats.protobuf.deserialize: Deserializer to convert proto array type object to flink array type data.
PbCodegenArrayDeserializer(Descriptors.FieldDescriptor, LogicalType, PbFormatContext) - Constructor for class org.apache.flink.formats.protobuf.deserialize.PbCodegenArrayDeserializer
PbCodegenArraySerializer - Class in org.apache.flink.formats.protobuf.serialize: Serializer to convert flink array type data to proto array type object.
PbCodegenArraySerializer(Descriptors.FieldDescriptor, LogicalType, PbFormatContext) - Constructor for class org.apache.flink.formats.protobuf.serialize.PbCodegenArraySerializer
PbCodegenDeserializeFactory - Class in org.apache.flink.formats.protobuf.deserialize: Codegen factory class which return PbCodegenDeserializer of different data type.
PbCodegenDeserializeFactory() - Constructor for class org.apache.flink.formats.protobuf.deserialize.PbCodegenDeserializeFactory
PbCodegenDeserializer - Interface in org.apache.flink.formats.protobuf.deserialize: PbCodegenDeserializer is responsible for converting protobuf object to flink internal object by codegen process.
PbCodegenException - Exception in org.apache.flink.formats.protobuf: Exception represents codegen error in row and proto conversion which is probably a bug.
PbCodegenException() - Constructor for exception org.apache.flink.formats.protobuf.PbCodegenException
PbCodegenException(String) - Constructor for exception org.apache.flink.formats.protobuf.PbCodegenException
PbCodegenException(String, Throwable) - Constructor for exception org.apache.flink.formats.protobuf.PbCodegenException
PbCodegenException(Throwable) - Constructor for exception org.apache.flink.formats.protobuf.PbCodegenException
PbCodegenMapDeserializer - Class in org.apache.flink.formats.protobuf.deserialize: Deserializer to convert proto map type object to flink map type data.
PbCodegenMapDeserializer(Descriptors.FieldDescriptor, MapType, PbFormatContext) - Constructor for class org.apache.flink.formats.protobuf.deserialize.PbCodegenMapDeserializer
PbCodegenMapSerializer - Class in org.apache.flink.formats.protobuf.serialize: Serializer to convert flink map type data to proto map type object.
PbCodegenMapSerializer(Descriptors.FieldDescriptor, MapType, PbFormatContext) - Constructor for class org.apache.flink.formats.protobuf.serialize.PbCodegenMapSerializer
PbCodegenRowDeserializer - Class in org.apache.flink.formats.protobuf.deserialize: Deserializer to convert proto message type object to flink row type data.
PbCodegenRowDeserializer(Descriptors.Descriptor, RowType, PbFormatContext) - Constructor for class org.apache.flink.formats.protobuf.deserialize.PbCodegenRowDeserializer
PbCodegenRowSerializer - Class in org.apache.flink.formats.protobuf.serialize: Serializer to convert flink row type data to proto row type object.
PbCodegenRowSerializer(Descriptors.Descriptor, RowType, PbFormatContext) - Constructor for class org.apache.flink.formats.protobuf.serialize.PbCodegenRowSerializer
PbCodegenSerializeFactory - Class in org.apache.flink.formats.protobuf.serialize: Codegen factory class which return PbCodegenSerializer of different data type.
PbCodegenSerializeFactory() - Constructor for class org.apache.flink.formats.protobuf.serialize.PbCodegenSerializeFactory
PbCodegenSerializer - Interface in org.apache.flink.formats.protobuf.serialize: PbCodegenSerializer is responsible for converting flink internal data object to protobuf object by codegen process.
PbCodegenSimpleDeserializer - Class in org.apache.flink.formats.protobuf.deserialize: Deserializer to convert proto simple type object to flink simple type data.
PbCodegenSimpleDeserializer(Descriptors.FieldDescriptor, LogicalType) - Constructor for class org.apache.flink.formats.protobuf.deserialize.PbCodegenSimpleDeserializer
PbCodegenSimpleSerializer - Class in org.apache.flink.formats.protobuf.serialize: Serializer to convert flink simple type data to proto simple type object.
PbCodegenSimpleSerializer(Descriptors.FieldDescriptor, LogicalType, PbFormatContext) - Constructor for class org.apache.flink.formats.protobuf.serialize.PbCodegenSimpleSerializer
PbCodegenUtils - Class in org.apache.flink.formats.protobuf.util: Codegen utils only used in protobuf format.
PbCodegenUtils() - Constructor for class org.apache.flink.formats.protobuf.util.PbCodegenUtils
PbCodegenVarId - Class in org.apache.flink.formats.protobuf.util: Singleton class for generating variable suffix number globally to avoid conflict in codegen sections.
PbConstant - Class in org.apache.flink.formats.protobuf: Keeps protobuf constants separately.
PbConstant() - Constructor for class org.apache.flink.formats.protobuf.PbConstant
PbDecodingFormat - Class in org.apache.flink.formats.protobuf: DecodingFormat for protobuf decoding.
PbDecodingFormat(PbFormatConfig) - Constructor for class org.apache.flink.formats.protobuf.PbDecodingFormat
pbDefaultValueCode(Descriptors.FieldDescriptor, PbFormatContext) - Static method in class org.apache.flink.formats.protobuf.util.PbCodegenUtils: Get protobuf default value from Descriptors.FieldDescriptor.
PbEncodingFormat - Class in org.apache.flink.formats.protobuf: EncodingFormat for protobuf encoding.
PbEncodingFormat(PbFormatConfig) - Constructor for class org.apache.flink.formats.protobuf.PbEncodingFormat
PbFileFormatFactory - Class in org.apache.flink.formats.protobuf: Throw a ValidationException when using Protobuf format factory for file system.
PbFileFormatFactory() - Constructor for class org.apache.flink.formats.protobuf.PbFileFormatFactory
PbFormatConfig - Class in org.apache.flink.formats.protobuf: Config of protobuf configs.
PbFormatConfig(String, boolean, boolean, String) - Constructor for class org.apache.flink.formats.protobuf.PbFormatConfig
PbFormatConfig.PbFormatConfigBuilder - Class in org.apache.flink.formats.protobuf: Builder of PbFormatConfig.
PbFormatConfigBuilder() - Constructor for class org.apache.flink.formats.protobuf.PbFormatConfig.PbFormatConfigBuilder
PbFormatContext - Class in org.apache.flink.formats.protobuf: store config and common information.
PbFormatContext(PbFormatConfig) - Constructor for class org.apache.flink.formats.protobuf.PbFormatContext
PbFormatFactory - Class in org.apache.flink.formats.protobuf: Table format factory for providing configured instances of Protobuf to RowData SerializationSchema and DeserializationSchema.
PbFormatFactory() - Constructor for class org.apache.flink.formats.protobuf.PbFormatFactory
PbFormatOptions - Class in org.apache.flink.formats.protobuf: This class holds configuration constants used by protobuf format.
PbFormatOptions() - Constructor for class org.apache.flink.formats.protobuf.PbFormatOptions
PbFormatUtils - Class in org.apache.flink.formats.protobuf.util: Protobuf function util.
PbFormatUtils() - Constructor for class org.apache.flink.formats.protobuf.util.PbFormatUtils
PbRowDataDeserializationSchema - Class in org.apache.flink.formats.protobuf.deserialize: Deserialization schema from Protobuf to Flink types.
PbRowDataDeserializationSchema(RowType, TypeInformation<RowData>, PbFormatConfig) - Constructor for class org.apache.flink.formats.protobuf.deserialize.PbRowDataDeserializationSchema
PbRowDataSerializationSchema - Class in org.apache.flink.formats.protobuf.serialize: Serialization schema from Flink to Protobuf types.
PbRowDataSerializationSchema(RowType, PbFormatConfig) - Constructor for class org.apache.flink.formats.protobuf.serialize.PbRowDataSerializationSchema
PbSchemaValidationUtils - Class in org.apache.flink.formats.protobuf.util: Validation class to verify protobuf definition and flink schema.
PbSchemaValidationUtils() - Constructor for class org.apache.flink.formats.protobuf.util.PbSchemaValidationUtils
PbToRowTypeUtil - Class in org.apache.flink.formats.protobuf.util: Generate Row type information according to pb descriptors.
PbToRowTypeUtil() - Constructor for class org.apache.flink.formats.protobuf.util.PbToRowTypeUtil
printWithLineNumber() - Method in class org.apache.flink.formats.protobuf.util.PbCodegenAppender
ProtobufInternalUtils - Class in com.google.protobuf: This class is to access internal method in protobuf package.
ProtobufInternalUtils() - Constructor for class com.google.protobuf.ProtobufInternalUtils
ProtoToRowConverter - Class in org.apache.flink.formats.protobuf.deserialize: ProtoToRowConverter can convert binary protobuf message data to flink row data by codegen process.
ProtoToRowConverter(RowType, PbFormatConfig) - Constructor for class org.apache.flink.formats.protobuf.deserialize.ProtoToRowConverter

R

READ_DEFAULT_VALUES - Static variable in class org.apache.flink.formats.protobuf.PbFormatOptions
readDefaultValues(boolean) - Method in class org.apache.flink.formats.protobuf.PbFormatConfig.PbFormatConfigBuilder
requiredOptions() - Method in class org.apache.flink.formats.protobuf.PbFileFormatFactory
requiredOptions() - Method in class org.apache.flink.formats.protobuf.PbFormatFactory
RowToProtoConverter - Class in org.apache.flink.formats.protobuf.serialize: RowToProtoConverter can convert flink row data to binary protobuf message data by codegen process.
RowToProtoConverter(RowType, PbFormatConfig) - Constructor for class org.apache.flink.formats.protobuf.serialize.RowToProtoConverter

S

serialize(RowData) - Method in class org.apache.flink.formats.protobuf.serialize.PbRowDataSerializationSchema
serialVersionUID - Static variable in class org.apache.flink.formats.protobuf.serialize.PbRowDataSerializationSchema
splitDeserializerRowTypeMethod(String, String, String, String) - Method in class org.apache.flink.formats.protobuf.PbFormatContext
splitSerializerRowTypeMethod(String, String, String, String) - Method in class org.apache.flink.formats.protobuf.PbFormatContext

U

underScoreToCamelCase(String, boolean) - Static method in class com.google.protobuf.ProtobufInternalUtils: convert underscore name to camel name.

V

validate(Descriptors.Descriptor, RowType) - Static method in class org.apache.flink.formats.protobuf.util.PbSchemaValidationUtils

W

WRITE_NULL_STRING_LITERAL - Static variable in class org.apache.flink.formats.protobuf.PbFormatOptions
writeNullStringLiterals(String) - Method in class org.apache.flink.formats.protobuf.PbFormatConfig.PbFormatConfigBuilder

A B C D E F G H I M N O P R S U V W
All Classes All Packages