Uses of Class
org.apache.flink.formats.avro.AvroFormatOptions.AvroEncoding

Packages that use AvroFormatOptions.AvroEncoding

Package	Description
org.apache.flink.formats.avro

Uses of AvroFormatOptions.AvroEncoding in org.apache.flink.formats.avro

Fields in org.apache.flink.formats.avro with type parameters of type AvroFormatOptions.AvroEncoding

Modifier and Type	Field and Description
static org.apache.flink.configuration.ConfigOption<AvroFormatOptions.AvroEncoding>	AvroFormatOptions.AVRO_ENCODING

Methods in org.apache.flink.formats.avro that return AvroFormatOptions.AvroEncoding

Modifier and Type	Method and Description
static AvroFormatOptions.AvroEncoding	AvroFormatOptions.AvroEncoding.valueOf(String name) Returns the enum constant of this type with the specified name.
static AvroFormatOptions.AvroEncoding[]	AvroFormatOptions.AvroEncoding.values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.flink.formats.avro with parameters of type AvroFormatOptions.AvroEncoding

Modifier and Type	Method and Description
static AvroSerializationSchema<org.apache.avro.generic.GenericRecord>	AvroSerializationSchema.forGeneric(org.apache.avro.Schema schema, AvroFormatOptions.AvroEncoding encoding) Creates AvroSerializationSchema that serializes GenericRecord using provided schema.
static AvroDeserializationSchema<org.apache.avro.generic.GenericRecord>	AvroDeserializationSchema.forGeneric(org.apache.avro.Schema schema, AvroFormatOptions.AvroEncoding encoding) Creates AvroDeserializationSchema that produces GenericRecord using provided schema.
static RegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord>	RegistryAvroSerializationSchema.forGeneric(org.apache.avro.Schema schema, SchemaCoder.SchemaCoderProvider schemaCoderProvider, AvroFormatOptions.AvroEncoding encoding)
static <T extends org.apache.avro.specific.SpecificRecord> AvroSerializationSchema<T>	AvroSerializationSchema.forSpecific(Class<T> tClass, AvroFormatOptions.AvroEncoding encoding) Creates AvroSerializationSchema that serializes SpecificRecord using provided schema.
static <T extends org.apache.avro.specific.SpecificRecord> AvroDeserializationSchema<T>	AvroDeserializationSchema.forSpecific(Class<T> tClass, AvroFormatOptions.AvroEncoding encoding) Creates AvroDeserializationSchema that produces classes that were generated from avro schema.
static <T extends org.apache.avro.specific.SpecificRecord> RegistryAvroSerializationSchema<T>	RegistryAvroSerializationSchema.forSpecific(Class<T> tClass, SchemaCoder.SchemaCoderProvider schemaCoderProvider, AvroFormatOptions.AvroEncoding encoding)

Constructors in org.apache.flink.formats.avro with parameters of type AvroFormatOptions.AvroEncoding

Constructor and Description
AvroRowDataDeserializationSchema(org.apache.flink.table.types.logical.RowType rowType, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo, AvroFormatOptions.AvroEncoding encoding) Creates an Avro deserialization schema for the given logical type.
AvroRowDataDeserializationSchema(org.apache.flink.table.types.logical.RowType rowType, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo, AvroFormatOptions.AvroEncoding encoding, boolean legacyTimestampMapping) Creates an Avro deserialization schema for the given logical type.
AvroRowDataSerializationSchema(org.apache.flink.table.types.logical.RowType rowType, AvroFormatOptions.AvroEncoding encoding) Creates an Avro serialization schema with the given record row type.
AvroRowDataSerializationSchema(org.apache.flink.table.types.logical.RowType rowType, AvroFormatOptions.AvroEncoding encoding, boolean legacyTimestampMapping) Creates an Avro serialization schema with the given record row type and legacy timestamp mapping flag.
AvroSerializationSchema(Class<T> recordClazz, org.apache.avro.Schema schema, AvroFormatOptions.AvroEncoding encoding) Creates an Avro deserialization schema.
RegistryAvroDeserializationSchema(Class<T> recordClazz, org.apache.avro.Schema reader, SchemaCoder.SchemaCoderProvider schemaCoderProvider, AvroFormatOptions.AvroEncoding encoding) Creates Avro deserialization schema that reads schema from input stream using provided SchemaCoder.
RegistryAvroSerializationSchema(Class<T> recordClazz, org.apache.avro.Schema schema, SchemaCoder.SchemaCoderProvider schemaCoderProvider, AvroFormatOptions.AvroEncoding encoding) Creates a Avro serialization schema.