@PublicEvolving public class GlueSchemaRegistryJsonSchemaCoder extends Object implements Serializable
GlueSchemaRegistryJsonSerializationSchema
and GlueSchemaRegistryJsonSerializationSchema
.Modifier | Constructor and Description |
---|---|
|
GlueSchemaRegistryJsonSchemaCoder(String transportName,
Map<String,Object> configs)
Constructor accepts transport name and configuration map for AWS Glue Schema Registry.
|
protected |
GlueSchemaRegistryJsonSchemaCoder(String transportName,
Map<String,Object> configs,
com.amazonaws.services.schemaregistry.serializers.GlueSchemaRegistrySerializationFacade glueSchemaRegistrySerializationFacade,
com.amazonaws.services.schemaregistry.deserializers.GlueSchemaRegistryDeserializationFacade glueSchemaRegistryDeserializationFacade) |
Modifier and Type | Method and Description |
---|---|
Object |
deserialize(byte[] bytes) |
byte[] |
registerSchemaAndSerialize(Object object) |
public GlueSchemaRegistryJsonSchemaCoder(String transportName, Map<String,Object> configs)
transportName
- topic name or stream name etc.configs
- configurations for AWS Glue Schema Registry@VisibleForTesting protected GlueSchemaRegistryJsonSchemaCoder(String transportName, Map<String,Object> configs, com.amazonaws.services.schemaregistry.serializers.GlueSchemaRegistrySerializationFacade glueSchemaRegistrySerializationFacade, com.amazonaws.services.schemaregistry.deserializers.GlueSchemaRegistryDeserializationFacade glueSchemaRegistryDeserializationFacade)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.