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