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.
|
ByteBuffer |
serialize(T element)
Serialize the given element into a ByteBuffer.
|
ByteBuffer serialize(T element)
element
- The element to serializeCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.