org.apache.flink.streaming.kafka.test.base
Classes
CustomWatermarkExtractor
KafkaEvent
KafkaEventSchema
KafkaExampleUtil
RollingAdditionMapper