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.
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.
IterateExample	Example illustrating iterations in Flink streaming.
IterateExample.InputMap	Map the inputs so that the next Fibonacci numbers can be calculated while preserving the original input tuple.
IterateExample.OutputMap	Giving back the input pair and the counter.
IterateExample.Step	Iteration step function that calculates the next Fibonacci number.
IterateExampleData	Data for IterateExampleITCase.
KafkaEventsGeneratorJob	Job to generate input events that are written to Kafka, for the StateMachineExample job.
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 that computes a simple word occurrence histogram over text files.
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.