org.apache.flink.statefun.flink.io.kinesis.polyglot
Classes
GenericKinesisEgressSerializer
GenericKinesisSinkProvider
RoutableProtobufKinesisIngressDeserializer
RoutableProtobufKinesisSourceProvider