Package org.apache.flink.streaming.tests.queryablestate

Class Summary

Class	Description
Email	Toy email resentation.
EmailId	POJO representing an EmailId.
EmailInformation	POJO representing some information about an email.
LabelSurrogate	A label surrogate.
QsConstants	A class containing the constants used in the end-to-end test.
QsStateClient	A simple implementation of a queryable state client.
QsStateProducer	Streaming application that creates an Email pojo with random ids and increasing timestamps and passes it to a stateful FlatMapFunction, where it is exposed as queryable state.

Enum Summary

Enum	Description
LabelSurrogate.Type	An exemplary enum.