A C D E F G H I L M N O R S T V W

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(Path, Class<E>) - Constructor for class org.apache.flink.formats.avro.AvroOutputFormat

AvroOutputFormat(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(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.

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.

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, 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.

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.

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>, Schema) - 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.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.

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(T) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer

copy(T, T) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer

copy(DataInputView, DataOutputView) - 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(SerializerConfig) - Method in class org.apache.flink.formats.avro.typeutils.AvroTypeInfo

createSerializer(ExecutionConfig) - Method in class org.apache.flink.formats.avro.typeutils.AvroTypeInfo

createSerializer(SerializerConfig) - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo

createSerializer(ExecutionConfig) - 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

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, AvroFormatOptions.AvroEncoding) - 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.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>, 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>) - 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.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(T) - Method in class org.apache.flink.formats.avro.AvroDeserializationSchema

isEndOfStream(RowData) - Method in class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema

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

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

O

open(FileInputSplit) - Method in class org.apache.flink.formats.avro.AvroInputFormat

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

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(Kryo, Input, Class<Schema>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer

read(byte[], int, int) - Method in class org.apache.flink.formats.avro.utils.FSDataInputStreamWrapper

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(Utf8) - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder

readString() - 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

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

A C D E F G H I L M N O R S T V W