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 Description static org.apache.flink.configuration.ConfigOption<AvroFormatOptions.AvroEncoding>AvroFormatOptions. AVRO_ENCODINGMethods in org.apache.flink.formats.avro that return AvroFormatOptions.AvroEncoding Modifier and Type Method Description static AvroFormatOptions.AvroEncodingAvroFormatOptions.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 Description static AvroDeserializationSchema<org.apache.avro.generic.GenericRecord>AvroDeserializationSchema. forGeneric(org.apache.avro.Schema schema, AvroFormatOptions.AvroEncoding encoding)CreatesAvroDeserializationSchemathat producesGenericRecordusing provided schema.static AvroSerializationSchema<org.apache.avro.generic.GenericRecord>AvroSerializationSchema. forGeneric(org.apache.avro.Schema schema, AvroFormatOptions.AvroEncoding encoding)CreatesAvroSerializationSchemathat serializesGenericRecordusing 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>
AvroDeserializationSchema<T>AvroDeserializationSchema. forSpecific(Class<T> tClass, AvroFormatOptions.AvroEncoding encoding)CreatesAvroDeserializationSchemathat produces classes that were generated from avro schema.static <T extends org.apache.avro.specific.SpecificRecord>
AvroSerializationSchema<T>AvroSerializationSchema. forSpecific(Class<T> tClass, AvroFormatOptions.AvroEncoding encoding)CreatesAvroSerializationSchemathat serializesSpecificRecordusing provided 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 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 providedSchemaCoder.RegistryAvroSerializationSchema(Class<T> recordClazz, org.apache.avro.Schema schema, SchemaCoder.SchemaCoderProvider schemaCoderProvider, AvroFormatOptions.AvroEncoding encoding)Creates a Avro serialization schema.
-