@PublicEvolving public class GlueSchemaRegistryAvroSchemaCoderProvider extends Object implements SchemaCoder.SchemaCoderProvider
GlueSchemaRegistryAvroSchemaCoder
.Constructor and Description |
---|
GlueSchemaRegistryAvroSchemaCoderProvider(Map<String,Object> configs) |
GlueSchemaRegistryAvroSchemaCoderProvider(String transportName,
Map<String,Object> configs)
Constructor used by
GlueSchemaRegistryAvroDeserializationSchema and GlueSchemaRegistryAvroSerializationSchema . |
Modifier and Type | Method and Description |
---|---|
GlueSchemaRegistryAvroSchemaCoder |
get()
Creates a new instance of
SchemaCoder . |
public GlueSchemaRegistryAvroSchemaCoderProvider(String transportName, Map<String,Object> configs)
GlueSchemaRegistryAvroDeserializationSchema
and GlueSchemaRegistryAvroSerializationSchema
.transportName
- topic name or stream name etc.configs
- configurations for AWS Glue Schema Registrypublic GlueSchemaRegistryAvroSchemaCoder get()
SchemaCoder.SchemaCoderProvider
SchemaCoder
. Each time it should create a new instance,
as it will be called on multiple nodes.get
in interface SchemaCoder.SchemaCoderProvider
SchemaCoder
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.