| Class | Description |
|---|---|
| AvroSchemaConverter |
Converts an Avro schema into Flink's type information.
|
| AvroSerializer<T> |
A serializer that serializes types via Avro.
|
| AvroSerializer.AvroSchemaSerializerConfigSnapshot |
A config snapshot for the Avro Serializer that stores the Avro Schema to check compatibility.
|
| AvroSerializer.AvroSerializerConfigSnapshot<T> | Deprecated
The
AvroSerializer.AvroSchemaSerializerConfigSnapshot should be used instead. |
| AvroTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> |
Special type information to generate a special AvroTypeInfo for Avro POJOs (implementing SpecificRecordBase, the typed Avro POJOs)
|
| BackwardsCompatibleAvroSerializer<T> |
An Avro serializer that can switch back to a KryoSerializer or a Pojo Serializer, if
it has to ensure compatibility with one of those.
|
| GenericRecordAvroTypeInfo |
TypeInformation for
GenericRecord. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.