Package org.apache.flink.streaming.connectors.kinesis.serialization

Interface Summary

Interface	Description
KinesisDeserializationSchema<T>	This is a deserialization schema specific for the Flink Kinesis Consumer.
KinesisSerializationSchema<T>	Kinesis-specific serialization schema, allowing users to specify a target stream based on a record's contents.

Class Summary

Class	Description
DynamoDBStreamsSchema	Schema used for deserializing DynamoDB streams records.
KinesisDeserializationSchemaWrapper<T>	A simple wrapper for using the DeserializationSchema with the KinesisDeserializationSchema interface.