Serialized Form

Package org.apache.flink.api.avro

Class org.apache.flink.api.avro.DataOutputEncoder extends org.apache.avro.io.Encoder implements Serializable

serialVersionUID:

1L

Serialized Fields

out

DataOutput out

Package org.apache.flink.api.java.io

Class org.apache.flink.api.java.io.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.api.java.io.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