Serialized Form

Package org.apache.flink.formats.avro

Class org.apache.flink.formats.avro.AvroDeserializationSchema extends Object implements Serializable

serialVersionUID:

-6766681879020862312L

Serialized Fields

recordClazz

Class<T> recordClazz

Class to deserialize to.

schemaString

String schemaString

Schema in case of GenericRecord for serialization purpose.

Class org.apache.flink.formats.avro.AvroInputFormat extends org.apache.flink.api.common.io.FileInputFormat<E> implements Serializable

serialVersionUID:

1L

Serialized Fields

avroValueType

Class<T> avroValueType

reuseAvroValue

boolean reuseAvroValue

lastSync

long lastSync

Class org.apache.flink.formats.avro.AvroOutputFormat extends org.apache.flink.api.common.io.FileOutputFormat<E> implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

avroValueType

Class<T> avroValueType

Class org.apache.flink.formats.avro.AvroRowDeserializationSchema extends org.apache.flink.api.common.serialization.AbstractDeserializationSchema<org.apache.flink.types.Row> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException

Throws:

ClassNotFoundException

IOException

writeObject

private void writeObject(ObjectOutputStream outputStream)
                  throws IOException

Throws:

IOException

Serialized Fields

recordClazz

Class<T> recordClazz

Avro record class for deserialization. Might be null if record class is not available.

schemaString

String schemaString

Schema string for deserialization.

Class org.apache.flink.formats.avro.AvroRowSerializationSchema extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException

Throws:

ClassNotFoundException

IOException

writeObject

private void writeObject(ObjectOutputStream outputStream)
                  throws IOException

Throws:

IOException

Serialized Fields

recordClazz

Class<T> recordClazz

Avro record class for serialization. Might be null if record class is not available.

schemaString

String schemaString

Schema string for deserialization.

Class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema extends AvroDeserializationSchema<T> implements Serializable

serialVersionUID:

-884738268437806062L

Serialized Fields

schemaCoderProvider

SchemaCoder.SchemaCoderProvider schemaCoderProvider

Provider for schema coder. Used for initializing in each task.

Package org.apache.flink.formats.avro.typeutils

Class org.apache.flink.formats.avro.typeutils.AvroSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable

serialVersionUID:

2L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

Serialized Fields

type

Class<T> type

schema

org.apache.flink.formats.avro.typeutils.SerializableAvroSchema schema

previousSchema

org.apache.flink.formats.avro.typeutils.SerializableAvroSchema previousSchema

Class org.apache.flink.formats.avro.typeutils.AvroTypeInfo extends org.apache.flink.api.java.typeutils.PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.avro.generic.GenericRecord> implements Serializable

serialVersionUID:

4141977586453820650L

Serialization Methods

readObject

private void readObject(ObjectInputStream ois)
                 throws ClassNotFoundException,
                        IOException

Throws:

ClassNotFoundException

IOException

writeObject

private void writeObject(ObjectOutputStream oos)
                  throws IOException

Throws:

IOException

Package org.apache.flink.formats.avro.utils

Class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.Schema> implements Serializable

serialVersionUID:

1L