Class | Description |
---|---|
AvroFactory<T> |
Creates Avro
DatumReader and DatumWriter . |
AvroSchemaConverter |
Converts an Avro schema into Flink's type information.
|
AvroSerializer<T> |
A serializer that serializes types via Avro.
|
AvroSerializer.AvroSchemaSerializerConfigSnapshot<T> | Deprecated |
AvroSerializerSnapshot<T> |
An
Avro specific implementation of a TypeSerializerSnapshot . |
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)
|
GenericRecordAvroTypeInfo |
TypeInformation for
GenericRecord . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.