Uses of Interface
org.apache.flink.formats.avro.SchemaCoder.SchemaCoderProvider
-
Packages that use SchemaCoder.SchemaCoderProvider Package Description org.apache.flink.formats.avro -
-
Uses of SchemaCoder.SchemaCoderProvider in org.apache.flink.formats.avro
Methods in org.apache.flink.formats.avro with parameters of type SchemaCoder.SchemaCoderProvider Modifier and Type Method Description static RegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord>RegistryAvroSerializationSchema. forGeneric(org.apache.avro.Schema schema, SchemaCoder.SchemaCoderProvider schemaCoderProvider)static <T extends org.apache.avro.specific.SpecificRecord>
RegistryAvroSerializationSchema<T>RegistryAvroSerializationSchema. forSpecific(Class<T> tClass, SchemaCoder.SchemaCoderProvider schemaCoderProvider)Constructors in org.apache.flink.formats.avro with parameters of type SchemaCoder.SchemaCoderProvider Constructor Description RegistryAvroDeserializationSchema(Class<T> recordClazz, org.apache.avro.Schema reader, SchemaCoder.SchemaCoderProvider schemaCoderProvider)Creates Avro deserialization schema that reads schema from input stream using providedSchemaCoder.RegistryAvroSerializationSchema(Class<T> recordClazz, org.apache.avro.Schema schema, SchemaCoder.SchemaCoderProvider schemaCoderProvider)Creates a Avro serialization schema.
-