@PublicEvolving public class GlueSchemaRegistryInputStreamDeserializer extends Object
Constructor and Description |
---|
GlueSchemaRegistryInputStreamDeserializer(com.amazonaws.services.schemaregistry.deserializers.GlueSchemaRegistryDeserializationFacade glueSchemaRegistryDeserializationFacade) |
GlueSchemaRegistryInputStreamDeserializer(Map<String,Object> configs)
Constructor accepts configuration map for AWS Deserializer.
|
Modifier and Type | Method and Description |
---|---|
org.apache.avro.Schema |
getSchemaAndDeserializedStream(InputStream in)
Get schema and remove extra Schema Registry information within input stream.
|
public GlueSchemaRegistryInputStreamDeserializer(Map<String,Object> configs)
configs
- configuration mappublic GlueSchemaRegistryInputStreamDeserializer(com.amazonaws.services.schemaregistry.deserializers.GlueSchemaRegistryDeserializationFacade glueSchemaRegistryDeserializationFacade)
public org.apache.avro.Schema getSchemaAndDeserializedStream(InputStream in) throws IOException
in
- input streamIOException
- Exception during decompressionCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.