T
- type of record it produces@PublicEvolving public class GlueSchemaRegistryJsonDeserializationSchema<T> extends Object implements DeserializationSchema<T>
DeserializationSchema.InitializationContext
Modifier and Type | Field and Description |
---|---|
protected GlueSchemaRegistryJsonSchemaCoder |
glueSchemaRegistryJsonSchemaCoder |
Modifier | Constructor and Description |
---|---|
protected |
GlueSchemaRegistryJsonDeserializationSchema(Class<T> recordClazz,
GlueSchemaRegistryJsonSchemaCoder glueSchemaRegistryJsonSchemaCoder) |
|
GlueSchemaRegistryJsonDeserializationSchema(Class<T> recordClazz,
String transportName,
Map<String,Object> configs)
Creates a JSON Schema deserialization schema.
|
Modifier and Type | Method and Description |
---|---|
T |
deserialize(byte[] bytes)
Deserializes the incoming byte array which contains bytes of AWS Glue Schema registry
information back to the original object.
|
TypeInformation<T> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
boolean |
isEndOfStream(T t)
Method to decide whether the element signals the end of the stream.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
deserialize, open
protected GlueSchemaRegistryJsonSchemaCoder glueSchemaRegistryJsonSchemaCoder
public GlueSchemaRegistryJsonDeserializationSchema(Class<T> recordClazz, String transportName, Map<String,Object> configs)
recordClazz
- class to which deserialize. Should be one of: com.amazonaws.services.schemaregistry.serializers.json.JsonDataWithSchema
, or user
defined POJO.transportName
- topic name or stream name etc.configs
- configuration map of AWS Glue Schema Registry@VisibleForTesting protected GlueSchemaRegistryJsonDeserializationSchema(Class<T> recordClazz, GlueSchemaRegistryJsonSchemaCoder glueSchemaRegistryJsonSchemaCoder)
public T deserialize(byte[] bytes)
deserialize
in interface DeserializationSchema<T>
bytes
- The incoming byte array to be deserializedpublic boolean isEndOfStream(T t)
DeserializationSchema
isEndOfStream
in interface DeserializationSchema<T>
t
- The element to test for the end-of-stream signal.public TypeInformation<T> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<T>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.