public class GlueSchemaRegistryAvroSchemaCoder extends Object implements SchemaCoder
GlueSchemaRegistryAvroDeserializationSchema
and GlueSchemaRegistryAvroSerializationSchema
.SchemaCoder.SchemaCoderProvider
Modifier | Constructor and Description |
---|---|
protected |
GlueSchemaRegistryAvroSchemaCoder(GlueSchemaRegistryInputStreamDeserializer glueSchemaRegistryInputStreamDeserializer) |
protected |
GlueSchemaRegistryAvroSchemaCoder(GlueSchemaRegistryOutputStreamSerializer glueSchemaRegistryOutputStreamSerializer) |
|
GlueSchemaRegistryAvroSchemaCoder(String transportName,
Map<String,Object> configs)
Constructor accepts transport name and configuration map for AWS Glue Schema Registry.
|
Modifier and Type | Method and Description |
---|---|
org.apache.avro.Schema |
readSchema(InputStream in) |
void |
writeSchema(org.apache.avro.Schema schema,
OutputStream out) |
public GlueSchemaRegistryAvroSchemaCoder(String transportName, Map<String,Object> configs)
transportName
- topic name or stream name etc.configs
- configurations for AWS Glue Schema Registry@VisibleForTesting protected GlueSchemaRegistryAvroSchemaCoder(GlueSchemaRegistryInputStreamDeserializer glueSchemaRegistryInputStreamDeserializer)
@VisibleForTesting protected GlueSchemaRegistryAvroSchemaCoder(GlueSchemaRegistryOutputStreamSerializer glueSchemaRegistryOutputStreamSerializer)
public org.apache.avro.Schema readSchema(InputStream in) throws IOException
readSchema
in interface SchemaCoder
IOException
public void writeSchema(org.apache.avro.Schema schema, OutputStream out) throws IOException
writeSchema
in interface SchemaCoder
IOException
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.