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

A

addAvroGenericDataArrayRegistration(LinkedHashMap<String, KryoRegistration>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils

addAvroSerializersIfRequired(ExecutionConfig, Class<?>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils

arrayNext() - Method in class org.apache.flink.formats.avro.utils.DataInputDecoder

Avro - Class in org.apache.flink.table.descriptors

Format descriptor for Apache Avro records.

Avro() - Constructor for class org.apache.flink.table.descriptors.Avro

Format descriptor for Apache Avro records.

AvroDeserializationSchema<T> - Class in org.apache.flink.formats.avro

Deserialization schema that deserializes from Avro binary format.

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.

AvroKryoSerializerUtils.JodaLocalDateSerializer - Class in org.apache.flink.formats.avro.utils

Avro logical types use JodaTime's LocalDate but Kryo is unable to serialize it properly (esp.

AvroKryoSerializerUtils.JodaLocalTimeSerializer - Class in org.apache.flink.formats.avro.utils

Avro logical types use JodaTime's LocalTime but Kryo is unable to serialize it properly (esp.

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.

AvroRowDeserializationSchema - Class in org.apache.flink.formats.avro

Deserialization schema from Avro bytes to Row.

AvroRowDeserializationSchema(Class<? extends SpecificRecord>) - Constructor for class org.apache.flink.formats.avro.AvroRowDeserializationSchema

Creates a Avro deserialization schema for the given specific record class.

AvroRowDeserializationSchema(String) - Constructor for class org.apache.flink.formats.avro.AvroRowDeserializationSchema

Creates a Avro deserialization schema for the given Avro schema string.

AvroRowFormatFactory - Class in org.apache.flink.formats.avro

Table format factory for providing configured instances of Avro-to-row SerializationSchema and DeserializationSchema.

AvroRowFormatFactory() - Constructor for class org.apache.flink.formats.avro.AvroRowFormatFactory

AvroRowSerializationSchema - Class in org.apache.flink.formats.avro

Serialization schema that serializes Row into Avro bytes.

AvroRowSerializationSchema(Class<? extends SpecificRecord>) - Constructor for class org.apache.flink.formats.avro.AvroRowSerializationSchema

Creates an Avro serialization schema for the given specific record class.

AvroRowSerializationSchema(String) - Constructor for class org.apache.flink.formats.avro.AvroRowSerializationSchema

Creates an Avro serialization schema for the given Avro schema string.

avroSchema(String) - Method in class org.apache.flink.table.descriptors.Avro

Sets the Avro schema for specific or generic Avro records.

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.

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

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.

AvroValidator - Class in org.apache.flink.table.descriptors

Validator for Avro.

AvroValidator() - Constructor for class org.apache.flink.table.descriptors.AvroValidator

C

canEqual(Object) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer

canEqual(Object) - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo

close() - Method in class org.apache.flink.formats.avro.AvroOutputFormat

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

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

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

copy(Kryo, LocalTime) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.JodaLocalTimeSerializer

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

createDeserializationSchema(Map<String, String>) - Method in class org.apache.flink.formats.avro.AvroRowFormatFactory

createInstance() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer

createSerializationSchema(Map<String, String>) - Method in class org.apache.flink.formats.avro.AvroRowFormatFactory

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

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

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

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

equals(Object) - Method in class org.apache.flink.formats.avro.AvroRowSerializationSchema

equals(Object) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer

equals(Object) - Method in class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo

F

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.

FORMAT_AVRO_SCHEMA - Static variable in class org.apache.flink.table.descriptors.AvroValidator

FORMAT_RECORD_CLASS - Static variable in class org.apache.flink.table.descriptors.AvroValidator

FORMAT_TYPE_VALUE - Static variable in class org.apache.flink.table.descriptors.AvroValidator

forSpecific(Class<T>) - Static method in class org.apache.flink.formats.avro.AvroDeserializationSchema

Creates AvroDeserializationSchema that produces classes that were generated from avro schema.

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

getDirectoryFileName(int) - Method in class org.apache.flink.formats.avro.AvroOutputFormat

getLength() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer

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

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

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

hashCode() - Method in class org.apache.flink.formats.avro.AvroRowSerializationSchema

hashCode() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer

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

I

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

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

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

J

JodaLocalDateSerializer() - Constructor for class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.JodaLocalDateSerializer

JodaLocalTimeSerializer() - Constructor for class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.JodaLocalTimeSerializer

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

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

org.apache.flink.table.descriptors - package org.apache.flink.table.descriptors

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

read(Kryo, Input, Class<LocalTime>) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.JodaLocalTimeSerializer

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

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

recordClass(Class<? extends SpecificRecord>) - Method in class org.apache.flink.table.descriptors.Avro

Sets the class of the Avro specific record.

RegistryAvroDeserializationSchema<T> - Class in org.apache.flink.formats.avro

Deserialization schema that deserializes from Avro binary 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.

reopen(FileInputSplit, Tuple2<Long, Long>) - Method in class org.apache.flink.formats.avro.AvroInputFormat

resolveSchemaCompatibility(TypeSerializer<T>) - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot

restoreSerializer() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot

S

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(Row) - Method in class org.apache.flink.formats.avro.AvroRowSerializationSchema

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

supportedFormatProperties() - Method in class org.apache.flink.formats.avro.AvroRowFormatFactory

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

T

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

toFormatProperties() - Method in class org.apache.flink.table.descriptors.Avro

toString() - Method in class org.apache.flink.formats.avro.typeutils.AvroSerializer

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

V

validate(DescriptorProperties) - Method in class org.apache.flink.table.descriptors.AvroValidator

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

write(Kryo, Output, LocalDate) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.JodaLocalDateSerializer

write(Kryo, Output, LocalTime) - Method in class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.JodaLocalTimeSerializer

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

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 J L M N O R S T V W