Package | Description |
---|---|
org.apache.flink.formats.avro.glue.schema.registry |
Modifier and Type | Method and Description |
---|---|
static GlueSchemaRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord> |
GlueSchemaRegistryAvroDeserializationSchema.forGeneric(org.apache.avro.Schema schema,
Map<String,Object> configs)
Creates
GlueSchemaRegistryAvroDeserializationSchema that produces GenericRecord using provided schema. |
static <T extends org.apache.avro.specific.SpecificRecord> |
GlueSchemaRegistryAvroDeserializationSchema.forSpecific(Class<T> clazz,
Map<String,Object> configs)
Creates
GlueSchemaRegistryAvroDeserializationSchema that produces classes that were
generated from avro schema. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.