All Classes

Class	Description
AggregateFunction<IN,ACC,OUT>	The AggregateFunction is a flexible aggregation function, characterized by the following features: The aggregates may use different types for input values, intermediate aggregates, and result type, to support a wide range of aggregation types.
AggregatingState<IN,OUT>	State interface for aggregating state, based on an AggregateFunction.
AggregatingState<IN,OUT>	State interface for aggregating state, based on an AggregateFunction.
AggregatingStateDeclaration<IN,ACC,OUT>	This represents a declaration of the aggregating state.
AppendingState<IN,OUT>	Base interface for partitioned state that supports adding elements and inspecting the current state.
AppendingState<IN,OUT>	Base interface for partitioned state that supports adding elements and inspecting the current state.
BiConsumerWithException<T,U,E extends Throwable>	A checked extension of the BiConsumer interface.
BiFunctionWithException<T,U,R,E extends Throwable>	BiFunction interface which can throw exceptions.
BroadcastState<K,V>	A type of state that can be created to store the state of a BroadcastStream.
BroadcastStateDeclaration<K,V>	This represents a declaration of the broadcast state.
CheckedSupplier<R>	Similar to Supplier but can throw Exception.
Function	The base interface for all user-defined functions.
FunctionWithException<T,R,E extends Throwable>	A functional interface for a Function that may throw exceptions.
IllegalRedistributionModeException	A special IllegalStateException indicating a mismatch in StateDeclaration.
KeySelector<IN,KEY>	The KeySelector allows to use deterministic objects for operations such as reduce, reduceGroup, join, coGroup, etc.
ListState<T>	State interface for partitioned list state in Operations.
ListState<T>	State interface for partitioned list state in Operations.
ListStateDeclaration<T>	This represents a declaration of the list state.
ListStateDeclaration.RedistributionStrategy	ListStateDeclaration.RedistributionStrategy is used to guide the assignment of states during rescaling.
LongFunctionWithException<R,E extends Throwable>	Similar to LongFunction but can throw Exception.
MapState<UK,UV>	State interface for partitioned key-value state.
MapState<UK,UV>	State interface for partitioned key-value state.
MapStateDeclaration<K,V>	This represents a declaration of the map state.
MemorySize	MemorySize is a representation of a number of bytes, viewable in different units.
MemorySize.MemoryUnit	Enum which defines memory unit, mostly used to parse value from configuration file.
MergingState<IN,OUT>	Extension of AppendingState that allows merging of state.
MergingState<IN,OUT>	Extension of AppendingState that allows merging of state.
QuadConsumer<S,T,U,V>	Operation which is performed on four given arguments.
QuadFunction<S,T,U,V,R>	Function which takes three arguments.
ReadOnlyBroadcastState<K,V>	A read-only view of the BroadcastState.
ReduceFunction<T>	Base interface for Reduce functions.
ReducingState<T>	State interface for reducing state.
ReducingState<T>	State interface for reducing state.
ReducingStateDeclaration<T>	This represents a declaration of the reducing state.
RunnableWithException	Similar to a Runnable, this interface is used to capture a block of code to be executed.
RuntimeExecutionMode	Runtime execution mode of DataStream programs.
SerializableFunction<T,R>	A Function that is also Serializable.
SerializableSupplier<T>	A serializable Supplier.
SerializableSupplierWithException<T,E extends Throwable>	A serializable SupplierWithException.
Sink<T>	Sink interface for DataStream api v2.
SlotSharingGroup	Describe the name and the different resource components of a slot sharing group.
SlotSharingGroup.Builder	Builder for SlotSharingGroup.
Source<T>	Source interface for DataStream api v2.
State	Interface that different types of partitioned state must implement.
State	Interface that different types of partitioned state must implement.
StateDeclaration	StateDeclaration represents a declaration of the specific state used.
StateDeclaration.RedistributionMode	StateDeclaration.RedistributionMode is used to indicate whether this state supports redistribution between partitions and how to redistribute this state during rescaling.
StateDeclarations	This is a helper class for declaring various states.
StateDeclarations.AggregatingStateDeclarationBuilder<IN,OUT,ACC>	Builder for AggregatingStateDeclaration.
StateDeclarations.ListStateDeclarationBuilder<T>	Builder for ListStateDeclaration.
StateDeclarations.MapStateDeclarationBuilder<K,V>	Builder for MapStateDeclaration.
StateDeclarations.ReducingStateDeclarationBuilder<T>	Builder for ReducingStateDeclaration.
StateDeclarations.ValueStateDeclarationBuilder<T>	Builder for ValueStateDeclaration.
StateFuture<T>	StateFuture is a future that act as a return value for async state interfaces.
StateIterator<T>	Asynchronous iterators allow to iterate over data that comes asynchronously, on-demand.
SupplierWithException<R,E extends Throwable>	A functional interface for a Supplier that may throw exceptions.
ThrowingConsumer<T,E extends Throwable>	This interface is basically Java's Consumer interface enhanced with the ability to throw an exception.
ThrowingRunnable<E extends Throwable>	Similar to a Runnable, this interface is used to capture a block of code to be executed.
TriConsumer<S,T,U>	Operation which is performed on three given arguments.
TriConsumerWithException<S,T,U,E extends Throwable>	A checked extension of the TriConsumer interface.
TriFunction<S,T,U,R>	Function which takes three arguments.
TriFunctionWithException<S,T,U,R,E extends Throwable>	Function which takes three arguments.
TypeDescriptor<T>	Descriptor interface to create TypeInformation instances.
TypeDescriptors	Descriptor interface to create TypeInformation instances.
TypeUtils	Utility class to create objects via reflection.
ValueState<T>	State interface for partitioned single-value state.
ValueState<T>	State interface for partitioned single-value state.
ValueStateDeclaration<T>	This represents a declaration of the value state.