Package org.apache.flink.streaming.examples.dsv2.eventtime

Class Summary

Class	Description
CountNewsClicks	This example illustrates how to count the number of clicks on each news at 1 hour after news publication.
CountNewsClicks.CountNewsClicksProcessFunction	This process function will consume CountNewsClicks.NewsEvent and count the number of clicks within 1 hour of the news publication and send the results CountNewsClicks.NewsClicks to the output.
CountNewsClicks.NewsClicks	The CountNewsClicks.NewsClicks represents the number of clicks on news within one hour following its publication.
CountNewsClicks.NewsEvent	The CountNewsClicks.NewsEvent represents an event on news, containing the event type, news id and the timestamp.

Enum Summary

Enum	Description
CountNewsClicks.NewsEventType	The type of CountNewsClicks.NewsEvent, note that only one event of type CountNewsClicks.NewsEventType.PUBLISH for each news.