Timer on ProcessFunction and KeyedProcessFunction Flink distinguishes between two key notions of time: processing time and event time. Processing time refers to the system time at which an event is processed, whereas event time is explicitly defined or configu…

Stream API (SourceFunction, AbstractSourceFunction and RichSourceFunction) in Flink In Flink's streaming API, there is a critical interface named Function, which extends Serializable: public interface Function extends Serializable { } Nearly all streaming APIs…