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.

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.