Utility interface for a provider of an input that can be closed.
Interface describing the methods that have to be implemented by local strategies for the CoGroup Pact.
Interface of an iterator that performs the logic of a match task.
BloomFilter is a probabilistic data structure for set membership check.
A standalone implementation of the
RuntimeContext, created by runtime UDF operators.
MutableObjectIterator that wraps a reader from an input channel and produces the
A simple iterator provider that returns a supplied iterator and does nothing when closed.
Configuration class which stores all relevant parameters required to set up the Pact tasks.
Enumeration of all available local processing strategies tasks.
Exception indicating that the parsed configuration was corrupt.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.