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 theRuntimeContext, created by runtime UDF operators.ReaderIterator<T> AMutableObjectIteratorthat 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.