T
- type of record it produces@PublicEvolving public class GlueSchemaRegistryAvroDeserializationSchema<T> extends RegistryAvroDeserializationSchema<T>
DeserializationSchema.InitializationContext
Modifier and Type | Method and Description |
---|---|
static GlueSchemaRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord> |
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> |
forSpecific(Class<T> clazz,
Map<String,Object> configs)
Creates
GlueSchemaRegistryAvroDeserializationSchema that produces classes that were
generated from avro schema. |
deserialize, equals, hashCode
forGeneric, forSpecific, getProducedType, isEndOfStream
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
deserialize, open
public static GlueSchemaRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord> forGeneric(org.apache.avro.Schema schema, Map<String,Object> configs)
GlueSchemaRegistryAvroDeserializationSchema
that produces GenericRecord
using provided schema.schema
- schema of produced recordsconfigs
- configuration map of AWS Glue Schema RegistryGenericRecord
public static <T extends org.apache.avro.specific.SpecificRecord> GlueSchemaRegistryAvroDeserializationSchema<T> forSpecific(Class<T> clazz, Map<String,Object> configs)
GlueSchemaRegistryAvroDeserializationSchema
that produces classes that were
generated from avro schema.clazz
- class of record to be producedconfigs
- configuration map of AWS Glue Schema RegistryCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.