T
- the type to be serialized@PublicEvolving public class GlueSchemaRegistryJsonSerializationSchema<T> extends Object implements SerializationSchema<T>
SerializationSchema.InitializationContext
Modifier and Type | Field and Description |
---|---|
protected GlueSchemaRegistryJsonSchemaCoder |
glueSchemaRegistryJsonSchemaCoder |
Modifier | Constructor and Description |
---|---|
protected |
GlueSchemaRegistryJsonSerializationSchema(GlueSchemaRegistryJsonSchemaCoder glueSchemaRegistryJsonSchemaCoder) |
|
GlueSchemaRegistryJsonSerializationSchema(String transportName,
Map<String,Object> configs)
Creates a JSON Schema serialization schema.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
serialize(T object)
Serializes the incoming element to a byte array containing bytes of AWS Glue Schema registry
information.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open
protected GlueSchemaRegistryJsonSchemaCoder glueSchemaRegistryJsonSchemaCoder
public GlueSchemaRegistryJsonSerializationSchema(String transportName, Map<String,Object> configs)
transportName
- topic name or stream name etc.configs
- configuration map of AWS Glue Schema Registry@VisibleForTesting protected GlueSchemaRegistryJsonSerializationSchema(GlueSchemaRegistryJsonSchemaCoder glueSchemaRegistryJsonSchemaCoder)
public byte[] serialize(T object)
serialize
in interface SerializationSchema<T>
object
- The incoming element to be serializedCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.