T
- @PublicEvolving public interface KinesisSerializationSchema<T> extends Serializable
Modifier and Type | Method and Description |
---|---|
String |
getTargetStream(T element)
Optional method to determine the target stream based on the element.
|
default void |
open(SerializationSchema.InitializationContext context)
Initialization method for the schema.
|
ByteBuffer |
serialize(T element)
Serialize the given element into a ByteBuffer.
|
default void open(SerializationSchema.InitializationContext context) throws Exception
serialize(Object)
and thus suitable for one time setup work.
The provided SerializationSchema.InitializationContext
can be used to access additional features such
as e.g. registering user metrics.
context
- Contextual information that can be used during initialization.Exception
ByteBuffer serialize(T element)
element
- The element to serializeCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.