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 | 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 | Description |
---|---|
LocalStrategy |
Enumeration of all available local processing strategies tasks.
|
Exception | Description |
---|---|
CorruptConfigurationException |
Exception indicating that the parsed configuration was corrupt.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.