All Classes

Class	Description
Alert	Data type for alerts.
AsyncClient	A simple asynchronous client that simulates interacting with an unreliable external service.
AsyncIOExample	Example to illustrate how to use AsyncFunction.
CarGeneratorFunction	A generator function for simulating car data.
CLI	A simple CLI parser for the WordCount example application.
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.
CountNewsClicks.NewsEventType	The type of CountNewsClicks.NewsEvent, note that only one event of type CountNewsClicks.NewsEventType.PUBLISH for each news.
CountProductSalesWindowing	Example illustrating how to use Window to count the sales of each product in each hour by DataStream API V2.
CountProductSalesWindowing.CountSalesQuantity	Count sales quantity per product.
CountProductSalesWindowing.Order	Pojo class for order.
CountProductSalesWindowing.ProductSales	The CountProductSalesWindowing.ProductSales class represents the count of product sales within one hour.
CountSales	This example shows how to count the cumulative sales of each product at the moment.
CountSales.CumulativeSales	CountSales.CumulativeSales represents the cumulative sales at a certain moment of a product.
CountSales.Order	Pojo class for Order.
DataGenerator	An example for generating data with a DataGeneratorSource.
DataGeneratorPerCheckpoint	An example for generating specific data per checkpoint with a DataGeneratorSource .
Event	Data type for events, consisting of the originating IP address and an event type.
EventDeSerializationSchema	A serializer and deserializer for the Event type.
EventsGenerator	A generator for events.
EventsGeneratorFunction	A generator function that produces the events on the fly.
EventType	The type of the event processed by the state machine.
EventTypeAndState	Simple combination of EventType and State.
GroupedProcessingTimeWindowExample	An example of grouped stream windowing into sliding time windows.
Join	Example illustrating a join between two data streams.
Join.GradeAndSalaryPojo	POJO class for grade and salary.
Join.GradePojo	POJO class for grades.
Join.SalaryPojo	POJO class for salaries.
KafkaStandaloneGenerator	A generator that pushes the data into Kafka.
MatrixVectorMul	Implements the matrix-vector multiplication program that shows how to use GPU resources in Flink.
SessionWindowing	An example of session windowing that keys events by ID and groups and counts them in session with gaps of 3 milliseconds.
SessionWindowingData	Data for SessionWindowingITCase.
SideOutputExample	An example that illustrates the use of side output.
SideOutputExample.Tokenizer	Implements the string tokenizer that splits sentences into words as a user-defined FlatMapFunction.
SocketWindowWordCount	Implements a streaming windowed version of the "WordCount" program.
SocketWindowWordCount.WordWithCount	Data type for words with count.
StandaloneThreadedGenerator	Base for standalone generators that use the state machine to create event sequences and push them for example into Kafka.
State	The State captures the main functionality of the state machine.
StateMachineExample	Main class of the state machine example.
ThrottledIterator<T>	A variant of the collection source (emits a sequence of elements as a stream) that supports throttling the emission rate.
TopSpeedWindowing	An example of grouped stream windowing where different eviction and trigger policies can be used.
TopSpeedWindowingExampleData	Data for TopSpeedWindowingExampleITCase.
Transition	A possible transition on a given event into a target state.
WindowJoin	Example illustrating a windowed stream join between two data streams.
WindowJoinSampleData	Sample data for the WindowJoin example.
WindowWordCount	Implements a windowed version of the streaming "WordCount" program.
WordCount	Implements the "WordCount" program by DataStream API V2 that computes a simple word occurrence histogram over text files.
WordCount	Implements the "WordCount" program that computes a simple word occurrence histogram over text files.
WordCount.Counter	Implements a word counter as a user-defined ProcessFunction that counts received words in streaming mode.
WordCount.Tokenizer	Implements the string tokenizer that splits sentences into words as a user-defined ProcessFunction.
WordCount.Tokenizer	Implements the string tokenizer that splits sentences into words as a user-defined FlatMapFunction.
WordCountData	Provides the default data sets used for the WordCount example program.