Index (Flink : Formats : Avro 1.19.3-cp4 API)

A B C D E F G H I J L M N O R S T V W X
All Classes All Packages

A

AbstractAvroBulkFormat<A,T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit> - Class in org.apache.flink.formats.avro: Provides a BulkFormat for Avro records.
AbstractAvroBulkFormat(Schema) - Constructor for class org.apache.flink.formats.avro.AbstractAvroBulkFormat
addAvroGenericDataArrayRegistration(LinkedHashMap<String, KryoRegistration>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
addAvroSerializersIfRequired(SerializerConfig, Class<?>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
addElement(T) - Method in class org.apache.flink.formats.avro.AvroBulkWriter
arrayNext() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
AVRO_ENCODING - Static variable in class org.apache.flink.formats.avro.AvroFormatOptions
AVRO_OUTPUT_CODEC - Static variable in class org.apache.flink.formats.avro.AvroFormatOptions
AVRO_TIMESTAMP_LEGACY_MAPPING - Static variable in class org.apache.flink.formats.avro.AvroFormatOptions
AvroBuilder<T> - Interface in org.apache.flink.formats.avro: A builder to create an AvroBulkWriter from an OutputStream.
AvroBulkWriter<T> - Class in org.apache.flink.formats.avro: A simple BulkWriter implementation that wraps an Avro DataFileWriter.
AvroBulkWriter(DataFileWriter<T>) - Constructor for class org.apache.flink.formats.avro.AvroBulkWriter: Create a new AvroBulkWriter wrapping the given Avro DataFileWriter.
AvroDeserializationSchema<T> - Class in org.apache.flink.formats.avro: Deserialization schema that deserializes from Avro binary format.
AvroFactory<T> - Class in org.apache.flink.formats.avro.typeutils: Creates Avro DatumReader and DatumWriter.
AvroFileFormatFactory - Class in org.apache.flink.formats.avro: Avro format factory for file system.
AvroFileFormatFactory() - Constructor for class org.apache.flink.formats.avro.AvroFileFormatFactory
AvroFormatFactory - Class in org.apache.flink.formats.avro: Table format factory for providing configured instances of Avro to RowData SerializationSchema and DeserializationSchema.
AvroFormatFactory() - Constructor for class org.apache.flink.formats.avro.AvroFormatFactory
AvroFormatOptions - Class in org.apache.flink.formats.avro: Options for the avro format.
AvroFormatOptions.AvroEncoding - Enum in org.apache.flink.formats.avro: Serialization types for Avro encoding, see AvroFormatOptions.AVRO_ENCODING.
AvroInputFormat<E> - Class in org.apache.flink.formats.avro: Provides a FileInputFormat for Avro records.
AvroInputFormat(Path, Class<E>) - Constructor for class org.apache.flink.formats.avro.AvroInputFormat
AvroKryoSerializerUtils - Class in org.apache.flink.formats.avro.utils: Utilities for integrating Avro serializers in Kryo.
AvroKryoSerializerUtils() - Constructor for class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
AvroKryoSerializerUtils.AvroSchemaSerializer - Class in org.apache.flink.formats.avro.utils: Slow serialization approach for Avro schemas.
AvroOutputFormat<E> - Class in org.apache.flink.formats.avro: FileOutputFormat for Avro records.
AvroOutputFormat(Class<E>) - Constructor for class org.apache.flink.formats.avro.AvroOutputFormat
AvroOutputFormat(Path, Class<E>) - Constructor for class org.apache.flink.formats.avro.AvroOutputFormat
AvroOutputFormat.Codec - Enum in org.apache.flink.formats.avro: Wrapper which encapsulates the supported codec and a related serialization byte.
AvroRowDataDeserializationSchema - Class in org.apache.flink.formats.avro: Deserialization schema from Avro bytes to RowData.
AvroRowDataDeserializationSchema(DeserializationSchema<GenericRecord>, AvroToRowDataConverters.AvroToRowDataConverter, TypeInformation<RowData>) - Constructor for class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema: Creates a Avro deserialization schema for the given logical type.
AvroRowDataDeserializationSchema(RowType, TypeInformation<RowData>) - Constructor for class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema: Creates an Avro deserialization schema for the given logical type.
AvroRowDataDeserializationSchema(RowType, TypeInformation<RowData>, AvroFormatOptions.AvroEncoding) - Constructor for class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema: Creates an Avro deserialization schema for the given logical type.
AvroRowDataDeserializationSchema(RowType, TypeInformation<RowData>, AvroFormatOptions.AvroEncoding, boolean) - Constructor for class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema: Creates an Avro deserialization schema for the given logical type.
AvroRowDataSerializationSchema - Class in org.apache.flink.formats.avro: Serialization schema that serializes RowData into Avro bytes.
AvroRowDataSerializationSchema(RowType) - Constructor for class org.apache.flink.formats.avro.AvroRowDataSerializationSchema: Creates an Avro serialization schema with the given record row type.
AvroRowDataSerializationSchema(RowType, SerializationSchema<GenericRecord>, RowDataToAvroConverters.RowDataToAvroConverter) - Constructor for class org.apache.flink.formats.avro.AvroRowDataSerializationSchema: Creates an Avro serialization schema with the given record row type, nested schema and runtime converters.
AvroRowDataSerializationSchema(RowType, AvroFormatOptions.AvroEncoding) - Constructor for class org.apache.flink.formats.avro.AvroRowDataSerializationSchema: Creates an Avro serialization schema with the given record row type.
AvroRowDataSerializationSchema(RowType, AvroFormatOptions.AvroEncoding, boolean) - Constructor for class org.apache.flink.formats.avro.AvroRowDataSerializationSchema: Creates an Avro serialization schema with the given record row type and legacy timestamp mapping flag.
AvroRowDeserializationSchema - Class in org.apache.flink.formats.avro: Deprecated.
The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own DeserializationSchema.
AvroRowDeserializationSchema(Class<? extends SpecificRecord>) - Constructor for class org.apache.flink.formats.avro.AvroRowDeserializationSchema: Deprecated.

Creates a Avro deserialization schema for the given specific record class.
AvroRowDeserializationSchema(String) - Constructor for class org.apache.flink.formats.avro.AvroRowDeserializationSchema: Deprecated.

Creates a Avro deserialization schema for the given Avro schema string.
AvroRowSerializationSchema - Class in org.apache.flink.formats.avro: Deprecated.
The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own SerializationSchema.
AvroRowSerializationSchema(Class<? extends SpecificRecord>) - Constructor for class org.apache.flink.formats.avro.AvroRowSerializationSchema: Deprecated.

Creates an Avro serialization schema for the given specific record class.
AvroRowSerializationSchema(String) - Constructor for class org.apache.flink.formats.avro.AvroRowSerializationSchema: Deprecated.

Creates an Avro serialization schema for the given Avro schema string.
AvroSchemaConverter - Class in org.apache.flink.formats.avro.typeutils: Converts an Avro schema into Flink's type information.
AvroSchemaSerializer() - Constructor for class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer
AvroSchemaSerializerConfigSnapshot() - Constructor for class org.apache.flink.formats.avro.typeutils.AvroSerializer.AvroSchemaSerializerConfigSnapshot: Deprecated.
AvroSerializationSchema<T> - Class in org.apache.flink.formats.avro: Serialization schema that serializes to Avro binary format.
AvroSerializationSchema(Class<T>, Schema, AvroFormatOptions.AvroEncoding) - Constructor for class org.apache.flink.formats.avro.AvroSerializationSchema: Creates an Avro deserialization schema.
AvroSerializer<T> - Class in org.apache.flink.formats.avro.typeutils: A serializer that serializes types via Avro.
AvroSerializer(Class<T>) - Constructor for class org.apache.flink.formats.avro.typeutils.AvroSerializer: Creates a new AvroSerializer for the type indicated by the given class.
AvroSerializer(Class<T>, Class<? extends T>) - Constructor for class org.apache.flink.formats.avro.typeutils.AvroSerializer: Deprecated.
Use AvroSerializer(Class) instead.
AvroSerializer(Class<T>, Schema) - Constructor for class org.apache.flink.formats.avro.typeutils.AvroSerializer: Creates a new AvroSerializer for the type indicated by the given class.
AvroSerializer.AvroSchemaSerializerConfigSnapshot<T> - Class in org.apache.flink.formats.avro.typeutils: Deprecated.
AvroSerializerSnapshot<T> - Class in org.apache.flink.formats.avro.typeutils: An Avro specific implementation of a TypeSerializerSnapshot.
AvroSerializerSnapshot() - Constructor for class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot
AvroToRowDataConverters - Class in org.apache.flink.formats.avro: Tool class used to convert from Avro GenericRecord to RowData.
AvroToRowDataConverters() - Constructor for class org.apache.flink.formats.avro.AvroToRowDataConverters
AvroToRowDataConverters.AvroToRowDataConverter - Interface in org.apache.flink.formats.avro: Runtime converter that converts Avro data structures into objects of Flink Table & SQL internal data structures.
AvroTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> - Class in org.apache.flink.formats.avro.typeutils: Special type information to generate a special AvroTypeInfo for Avro POJOs (implementing SpecificRecordBase, the typed Avro POJOs)
AvroTypeInfo(Class<T>) - Constructor for class org.apache.flink.formats.avro.typeutils.AvroTypeInfo: Creates a new Avro type info for the given class.
AvroWriterFactory<T> - Class in org.apache.flink.formats.avro: A factory that creates an AvroBulkWriter.
AvroWriterFactory(AvroBuilder<T>) - Constructor for class org.apache.flink.formats.avro.AvroWriterFactory: Creates a new AvroWriterFactory using the given builder to assemble the ParquetWriter.
AvroWriters - Class in org.apache.flink.formats.avro: Convenience builder to create AvroWriterFactory instances for the different Avro types.

B

BINARY - org.apache.flink.formats.avro.AvroFormatOptions.AvroEncoding
BZIP2 - org.apache.flink.formats.avro.AvroOutputFormat.Codec

C

canEqual(Object) - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo
checkAvroInitialized() - Method in class org.apache.flink.formats.avro.AvroSerializationSchema
checkAvroInitialized() - Method in class org.apache.flink.formats.avro.RegistryAvroSerializationSchema
close() - Method in class org.apache.flink.formats.avro.AvroOutputFormat
close() - Method in class org.apache.flink.formats.avro.utils.FSDataInputStreamWrapper
convert(Object) - Method in interface org.apache.flink.formats.avro.AvroToRowDataConverters.AvroToRowDataConverter
convert(Schema, Object) - Method in interface org.apache.flink.formats.avro.RowDataToAvroConverters.RowDataToAvroConverter
convertToDataType(String) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts an Avro schema string into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.
convertToDataType(String, boolean) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts an Avro schema string into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.
convertToSchema(LogicalType) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts Flink SQL LogicalType (can be nested) into an Avro schema.
convertToSchema(LogicalType, boolean) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts Flink SQL LogicalType (can be nested) into an Avro schema.
convertToSchema(LogicalType, String) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts Flink SQL LogicalType (can be nested) into an Avro schema.
convertToSchema(LogicalType, String, boolean) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts Flink SQL LogicalType (can be nested) into an Avro schema.
convertToTypeInfo(Class<T>) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts an Avro class into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.
convertToTypeInfo(Class<T>, boolean) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts an Avro class into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.
convertToTypeInfo(String) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts an Avro schema string into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.
convertToTypeInfo(String, boolean) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter: Converts an Avro schema string into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
copy(T) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
copy(T, T) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
create(FSDataOutputStream) - Method in class org.apache.flink.formats.avro.AvroWriterFactory
createAvroSerializer(Class<T>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
createAvroTypeInfo(Class<T>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
createConverter() - Method in class org.apache.flink.formats.avro.AbstractAvroBulkFormat
createConverter(LogicalType) - Static method in class org.apache.flink.formats.avro.RowDataToAvroConverters: Creates a runtime converter according to the given logical type that converts objects of Flink Table & SQL internal data structures to corresponding Avro data structures.
createConverter(LogicalType, boolean) - Static method in class org.apache.flink.formats.avro.RowDataToAvroConverters
createDecodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.avro.AvroFileFormatFactory
createDecodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.avro.AvroFormatFactory
createEncodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.avro.AvroFileFormatFactory
createEncodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.avro.AvroFormatFactory
createInstance() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
createReader(Configuration, SplitT) - Method in class org.apache.flink.formats.avro.AbstractAvroBulkFormat
createReusedAvroRecord() - Method in class org.apache.flink.formats.avro.AbstractAvroBulkFormat
createRowConverter(RowType) - Static method in class org.apache.flink.formats.avro.AvroToRowDataConverters
createRowConverter(RowType, boolean) - Static method in class org.apache.flink.formats.avro.AvroToRowDataConverters
createSerializer(ExecutionConfig) - Method in class org.apache.flink.formats.avro.typeutils.AvroTypeInfo
createSerializer(ExecutionConfig) - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo
createSerializer(SerializerConfig) - Method in class org.apache.flink.formats.avro.typeutils.AvroTypeInfo
createSerializer(SerializerConfig) - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo
createWriter(OutputStream) - Method in interface org.apache.flink.formats.avro.AvroBuilder: Creates and configures an Avro writer to the given output file.

D

DataInputDecoder - Class in org.apache.flink.formats.avro.utils: A Decoder that reads from a DataInput.
DataInputDecoder() - Constructor for class org.apache.flink.formats.avro.utils.DataInputDecoder
DataOutputEncoder - Class in org.apache.flink.formats.avro.utils: An Encoder that writes data to a DataOutput.
DataOutputEncoder() - Constructor for class org.apache.flink.formats.avro.utils.DataOutputEncoder
DEFLATE - org.apache.flink.formats.avro.AvroOutputFormat.Codec
deserialize(byte[]) - Method in class org.apache.flink.formats.avro.AvroDeserializationSchema
deserialize(byte[]) - Method in class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema
deserialize(byte[]) - Method in class org.apache.flink.formats.avro.AvroRowDeserializationSchema: Deprecated.
deserialize(byte[]) - Method in class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema
deserialize(DataInputView) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
deserialize(T, DataInputView) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
duplicate() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer

E

equals(Object) - Method in class org.apache.flink.formats.avro.AvroDeserializationSchema
equals(Object) - Method in class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema
equals(Object) - Method in class org.apache.flink.formats.avro.AvroRowDataSerializationSchema
equals(Object) - Method in class org.apache.flink.formats.avro.AvroRowDeserializationSchema: Deprecated.
equals(Object) - Method in class org.apache.flink.formats.avro.AvroRowSerializationSchema: Deprecated.
equals(Object) - Method in class org.apache.flink.formats.avro.AvroSerializationSchema
equals(Object) - Method in class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema
equals(Object) - Method in class org.apache.flink.formats.avro.RegistryAvroSerializationSchema
equals(Object) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
equals(Object) - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo
extractAvroSpecificSchema(Class<T>, SpecificData) - Static method in class org.apache.flink.formats.avro.typeutils.AvroFactory: Extracts an Avro Schema from a SpecificRecord.
extractValueTypeToAvroMap(LogicalType) - Static method in class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter

F

factoryIdentifier() - Method in class org.apache.flink.formats.avro.AvroFileFormatFactory
factoryIdentifier() - Method in class org.apache.flink.formats.avro.AvroFormatFactory
finish() - Method in class org.apache.flink.formats.avro.AvroBulkWriter
flush() - Method in class org.apache.flink.formats.avro.AvroBulkWriter
flush() - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
forGeneric(Schema) - Static method in class org.apache.flink.formats.avro.AvroDeserializationSchema: Creates AvroDeserializationSchema that produces GenericRecord using provided schema.
forGeneric(Schema) - Static method in class org.apache.flink.formats.avro.AvroSerializationSchema: Creates AvroSerializationSchema that serializes GenericRecord using provided schema.
forGeneric(Schema, AvroFormatOptions.AvroEncoding) - Static method in class org.apache.flink.formats.avro.AvroDeserializationSchema: Creates AvroDeserializationSchema that produces GenericRecord using provided schema.
forGeneric(Schema, AvroFormatOptions.AvroEncoding) - Static method in class org.apache.flink.formats.avro.AvroSerializationSchema: Creates AvroSerializationSchema that serializes GenericRecord using provided schema.
forGeneric(Schema, SchemaCoder.SchemaCoderProvider) - Static method in class org.apache.flink.formats.avro.RegistryAvroSerializationSchema
forGeneric(Schema, SchemaCoder.SchemaCoderProvider, AvroFormatOptions.AvroEncoding) - Static method in class org.apache.flink.formats.avro.RegistryAvroSerializationSchema
forGenericRecord(Schema) - Static method in class org.apache.flink.formats.avro.AvroWriters: Creates an AvroWriterFactory that accepts and writes Avro generic types.
forReflectRecord(Class<T>) - Static method in class org.apache.flink.formats.avro.AvroWriters: Creates an AvroWriterFactory for the given type.
forSpecific(Class<T>) - Static method in class org.apache.flink.formats.avro.AvroDeserializationSchema: Creates AvroDeserializationSchema that produces classes that were generated from avro schema.
forSpecific(Class<T>) - Static method in class org.apache.flink.formats.avro.AvroSerializationSchema: Creates AvroSerializationSchema that serializes SpecificRecord using provided schema.
forSpecific(Class<T>, AvroFormatOptions.AvroEncoding) - Static method in class org.apache.flink.formats.avro.AvroDeserializationSchema: Creates AvroDeserializationSchema that produces classes that were generated from avro schema.
forSpecific(Class<T>, AvroFormatOptions.AvroEncoding) - Static method in class org.apache.flink.formats.avro.AvroSerializationSchema: Creates AvroSerializationSchema that serializes SpecificRecord using provided schema.
forSpecific(Class<T>, SchemaCoder.SchemaCoderProvider) - Static method in class org.apache.flink.formats.avro.RegistryAvroSerializationSchema
forSpecific(Class<T>, SchemaCoder.SchemaCoderProvider, AvroFormatOptions.AvroEncoding) - Static method in class org.apache.flink.formats.avro.RegistryAvroSerializationSchema
forSpecificRecord(Class<T>) - Static method in class org.apache.flink.formats.avro.AvroWriters: Creates an AvroWriterFactory for an Avro specific type.
forwardOptions() - Method in class org.apache.flink.formats.avro.AvroFileFormatFactory
FSDataInputStreamWrapper - Class in org.apache.flink.formats.avro.utils: Code copy pasted from org.apache.avro.mapred.FSInput (which is Apache licensed as well).
FSDataInputStreamWrapper(FSDataInputStream, long) - Constructor for class org.apache.flink.formats.avro.utils.FSDataInputStreamWrapper

G

GenericRecordAvroTypeInfo - Class in org.apache.flink.formats.avro.typeutils: TypeInformation for GenericRecord.
GenericRecordAvroTypeInfo(Schema) - Constructor for class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo
get() - Method in interface org.apache.flink.formats.avro.SchemaCoder.SchemaCoderProvider: Creates a new instance of SchemaCoder.
getArity() - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo
getCurrentState() - Method in class org.apache.flink.formats.avro.AvroInputFormat
getCurrentVersion() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot
getDatumWriter() - Method in class org.apache.flink.formats.avro.AvroSerializationSchema
getDescription() - Method in enum org.apache.flink.formats.avro.AvroFormatOptions.AvroEncoding
getDirectoryFileName(int) - Method in class org.apache.flink.formats.avro.AvroOutputFormat
getEncoder() - Method in class org.apache.flink.formats.avro.AvroSerializationSchema
getLength() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
getOutputStream() - Method in class org.apache.flink.formats.avro.AvroSerializationSchema
getProducedType() - Method in class org.apache.flink.formats.avro.AvroDeserializationSchema
getProducedType() - Method in class org.apache.flink.formats.avro.AvroInputFormat
getProducedType() - Method in class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema
getProducedType() - Method in class org.apache.flink.formats.avro.AvroRowDeserializationSchema: Deprecated.
getRecordsReadFromBlock() - Method in class org.apache.flink.formats.avro.AvroInputFormat
getSchema() - Method in class org.apache.flink.formats.avro.AvroSerializationSchema
getSpecificDataForClass(Class<T>, ClassLoader) - Static method in class org.apache.flink.formats.avro.typeutils.AvroFactory: Creates a SpecificData object for a given class.
getTotalFields() - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo
getType() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
getTypeClass() - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo

H

hashCode() - Method in class org.apache.flink.formats.avro.AvroDeserializationSchema
hashCode() - Method in class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema
hashCode() - Method in class org.apache.flink.formats.avro.AvroRowDataSerializationSchema
hashCode() - Method in class org.apache.flink.formats.avro.AvroRowDeserializationSchema: Deprecated.
hashCode() - Method in class org.apache.flink.formats.avro.AvroRowSerializationSchema: Deprecated.
hashCode() - Method in class org.apache.flink.formats.avro.AvroSerializationSchema
hashCode() - Method in class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema
hashCode() - Method in class org.apache.flink.formats.avro.RegistryAvroSerializationSchema
hashCode() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
hashCode() - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo

I

IDENTIFIER - Static variable in class org.apache.flink.formats.avro.AvroFileFormatFactory
IDENTIFIER - Static variable in class org.apache.flink.formats.avro.AvroFormatFactory
isBasicType() - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo
isEndOfStream(RowData) - Method in class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema
isEndOfStream(T) - Method in class org.apache.flink.formats.avro.AvroDeserializationSchema
isImmutableType() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
isKeyType() - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo
isSplittable() - Method in class org.apache.flink.formats.avro.AbstractAvroBulkFormat
isTupleType() - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo

J

JSON - org.apache.flink.formats.avro.AvroFormatOptions.AvroEncoding

L

length() - Method in class org.apache.flink.formats.avro.utils.FSDataInputStreamWrapper

M

mapNext() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
MutableByteArrayInputStream - Class in org.apache.flink.formats.avro.utils: An extension of the ByteArrayInputStream that allows to change a buffer that should be read without creating a new ByteArrayInputStream instance.
MutableByteArrayInputStream() - Constructor for class org.apache.flink.formats.avro.utils.MutableByteArrayInputStream

N

nextRecord(E) - Method in class org.apache.flink.formats.avro.AvroInputFormat
NULL - org.apache.flink.formats.avro.AvroOutputFormat.Codec

O

open(int, int) - Method in class org.apache.flink.formats.avro.AvroOutputFormat
open(DeserializationSchema.InitializationContext) - Method in class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema
open(SerializationSchema.InitializationContext) - Method in class org.apache.flink.formats.avro.AvroRowDataSerializationSchema
open(SerializationSchema.InitializationContext) - Method in class org.apache.flink.formats.avro.AvroSerializationSchema
open(FileInputSplit) - Method in class org.apache.flink.formats.avro.AvroInputFormat
optionalOptions() - Method in class org.apache.flink.formats.avro.AvroFileFormatFactory
optionalOptions() - Method in class org.apache.flink.formats.avro.AvroFormatFactory
org.apache.flink.formats.avro - package org.apache.flink.formats.avro
org.apache.flink.formats.avro.typeutils - package org.apache.flink.formats.avro.typeutils
org.apache.flink.formats.avro.utils - package org.apache.flink.formats.avro.utils

R

reachedEnd() - Method in class org.apache.flink.formats.avro.AvroInputFormat
read(byte[], int, int) - Method in class org.apache.flink.formats.avro.utils.FSDataInputStreamWrapper
read(Kryo, Input, Class<Schema>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer
readArrayStart() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readBoolean() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readBytes(ByteBuffer) - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readDouble() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readEnum() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readerSchema - Variable in class org.apache.flink.formats.avro.AbstractAvroBulkFormat
readFixed(byte[], int, int) - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readFloat() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readIndex() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readInt() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readLong() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readMapStart() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readNull() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readSchema(InputStream) - Method in interface org.apache.flink.formats.avro.SchemaCoder
readSnapshot(int, DataInputView, ClassLoader) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot
readString() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readString(Utf8) - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
readVarLongCount(DataInput) - Static method in class org.apache.flink.formats.avro.utils.DataInputDecoder
RegistryAvroDeserializationSchema<T> - Class in org.apache.flink.formats.avro: Deserialization schema that deserializes from Avro format using SchemaCoder.
RegistryAvroDeserializationSchema(Class<T>, Schema, SchemaCoder.SchemaCoderProvider) - Constructor for class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema: Creates Avro deserialization schema that reads schema from input stream using provided SchemaCoder.
RegistryAvroDeserializationSchema(Class<T>, Schema, SchemaCoder.SchemaCoderProvider, AvroFormatOptions.AvroEncoding) - Constructor for class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema: Creates Avro deserialization schema that reads schema from input stream using provided SchemaCoder.
RegistryAvroSerializationSchema<T> - Class in org.apache.flink.formats.avro: Serialization schema that serializes to Avro format.
RegistryAvroSerializationSchema(Class<T>, Schema, SchemaCoder.SchemaCoderProvider) - Constructor for class org.apache.flink.formats.avro.RegistryAvroSerializationSchema: Creates a Avro serialization schema.
RegistryAvroSerializationSchema(Class<T>, Schema, SchemaCoder.SchemaCoderProvider, AvroFormatOptions.AvroEncoding) - Constructor for class org.apache.flink.formats.avro.RegistryAvroSerializationSchema: Creates a Avro serialization schema.
reopen(FileInputSplit, Tuple2<Long, Long>) - Method in class org.apache.flink.formats.avro.AvroInputFormat
requiredOptions() - Method in class org.apache.flink.formats.avro.AvroFileFormatFactory
requiredOptions() - Method in class org.apache.flink.formats.avro.AvroFormatFactory
resolveSchemaCompatibility(TypeSerializerSnapshot<T>) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot
restoreReader(Configuration, SplitT) - Method in class org.apache.flink.formats.avro.AbstractAvroBulkFormat
restoreSerializer() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot
RowDataToAvroConverters - Class in org.apache.flink.formats.avro: Tool class used to convert from RowData to Avro GenericRecord.
RowDataToAvroConverters() - Constructor for class org.apache.flink.formats.avro.RowDataToAvroConverters
RowDataToAvroConverters.RowDataToAvroConverter - Interface in org.apache.flink.formats.avro: Runtime converter that converts objects of Flink Table & SQL internal data structures to corresponding Avro data structures.

S

schemaCoder - Variable in class org.apache.flink.formats.avro.RegistryAvroSerializationSchema
SchemaCoder - Interface in org.apache.flink.formats.avro: Schema coder that allows reading schema that is somehow embedded into serialized record.
SchemaCoder.SchemaCoderProvider - Interface in org.apache.flink.formats.avro: Provider for SchemaCoder.
seek(long) - Method in class org.apache.flink.formats.avro.utils.FSDataInputStreamWrapper
serialize(RowData) - Method in class org.apache.flink.formats.avro.AvroRowDataSerializationSchema
serialize(Row) - Method in class org.apache.flink.formats.avro.AvroRowSerializationSchema: Deprecated.
serialize(T) - Method in class org.apache.flink.formats.avro.AvroSerializationSchema
serialize(T) - Method in class org.apache.flink.formats.avro.RegistryAvroSerializationSchema
serialize(T, DataOutputView) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
setBuffer(byte[]) - Method in class org.apache.flink.formats.avro.utils.MutableByteArrayInputStream: Set buffer that can be read via the InputStream interface and reset the input stream.
setCodec(AvroOutputFormat.Codec) - Method in class org.apache.flink.formats.avro.AvroOutputFormat: Set avro codec for compression.
setIn(DataInput) - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
setItemCount(long) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
setOut(DataOutput) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
setReuseAvroValue(boolean) - Method in class org.apache.flink.formats.avro.AvroInputFormat: Sets the flag whether to reuse the Avro value instance for all records.
setSchema(Schema) - Method in class org.apache.flink.formats.avro.AvroOutputFormat
setUnsplittable(boolean) - Method in class org.apache.flink.formats.avro.AvroInputFormat: If set, the InputFormat will only read entire files.
skipArray() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
skipBytes() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
skipFixed(int) - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
skipMap() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
skipString() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder
SNAPPY - org.apache.flink.formats.avro.AvroOutputFormat.Codec
snapshotConfiguration() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
startItem() - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
supportsMultiPaths() - Method in class org.apache.flink.formats.avro.AvroInputFormat

T

tell() - Method in class org.apache.flink.formats.avro.utils.FSDataInputStreamWrapper
toString() - Method in enum org.apache.flink.formats.avro.AvroFormatOptions.AvroEncoding
toString() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer
toString() - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo

V

valueOf(String) - Static method in enum org.apache.flink.formats.avro.AvroFormatOptions.AvroEncoding: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.formats.avro.AvroOutputFormat.Codec: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.flink.formats.avro.AvroFormatOptions.AvroEncoding: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.formats.avro.AvroOutputFormat.Codec: Returns an array containing the constants of this enum type, in the order they are declared.

W

write(Kryo, Output, Schema) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer
writeArrayEnd() - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeArrayStart() - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeBoolean(boolean) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeBytes(byte[], int, int) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeBytes(ByteBuffer) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeDouble(double) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeEnum(int) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeFixed(byte[], int, int) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeFloat(float) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeIndex(int) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeInt(int) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeLong(long) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeMapEnd() - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeMapStart() - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeNull() - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeRecord(E) - Method in class org.apache.flink.formats.avro.AvroOutputFormat
writeSchema(Schema, OutputStream) - Method in interface org.apache.flink.formats.avro.SchemaCoder
writeSnapshot(DataOutputView) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot
writeString(String) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeString(Utf8) - Method in class org.apache.flink.formats.avro.utils.DataOutputEncoder
writeVarLongCount(DataOutput, long) - Static method in class org.apache.flink.formats.avro.utils.DataOutputEncoder

X

XZ - org.apache.flink.formats.avro.AvroOutputFormat.Codec

A B C D E F G H I J L M N O R S T V W X
All Classes All Packages