Package org.apache.flink.streaming.kafka.test.base

Class Summary

Class	Description
CustomWatermarkExtractor	A custom AssignerWithPeriodicWatermarks, that simply assumes that the input stream records are strictly ascending.
KafkaEvent	The event type used in the Kafka010Example.
KafkaEventSchema	The serialization schema for the KafkaEvent type.
KafkaExampleUtil	The util class for kafka example.
RollingAdditionMapper	A RichMapFunction that continuously outputs the current total frequency count of a key.