public interface JoinTaskIterator<V1,V2,O>
Modifier and Type | Method and Description |
---|---|
void |
abort()
Aborts the matching process.
|
boolean |
callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction,
Collector<O> collector)
Moves the internal pointer to the next key that both inputs share.
|
void |
close()
General-purpose close method.
|
void |
open()
General-purpose open method.
|
void open() throws IOException, MemoryAllocationException, InterruptedException
IOException
- Thrown, if an I/O error occurred while preparing the data. An example is
a failing external sort.MemoryAllocationException
- Thrown, if the internal strategy could not allocate the
memory it needs.InterruptedException
- Thrown, if the thread was interrupted during the initialization
process.void close()
boolean callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction, Collector<O> collector) throws Exception
matchFunction
- The match stub containing the match function which is called with the
keys.collector
- The collector to pass the match function.Exception
- Exceptions from the user code are forwarded.void abort()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.