Package org.apache.flink.runtime.operators.util

Interface Summary

Interface	Description
CloseableInputProvider<E>	Utility interface for a provider of an input that can be closed.
CoGroupTaskIterator<T1,T2>	Interface describing the methods that have to be implemented by local strategies for the CoGroup Pact.
JoinTaskIterator<V1,V2,O>	Interface of an iterator that performs the logic of a match task.

Class Summary

Class	Description
BitSet
BloomFilter	BloomFilter is a probabilistic data structure for set membership check.
DistributedRuntimeUDFContext	A standalone implementation of the RuntimeContext, created by runtime UDF operators.
ReaderIterator<T>	A MutableObjectIterator that wraps a reader from an input channel and produces the reader's records.
SimpleCloseableInputProvider<E>	A simple iterator provider that returns a supplied iterator and does nothing when closed.
TaskConfig	Configuration class which stores all relevant parameters required to set up the Pact tasks.
TaskConfig.DelegatingConfiguration	A configuration that manages a subset of keys with a common prefix from a given configuration.

Enum Summary

Enum	Description
LocalStrategy	Enumeration of all available local processing strategies tasks.

Exception Summary

Exception	Description
CorruptConfigurationException	Exception indicating that the parsed configuration was corrupt.