public class NonReusingMergeOuterJoinIterator<T1,T2,O> extends AbstractMergeOuterJoinIterator<T1,T2,O>
blockHeadCopy, copy1, copy2, iterator1, iterator2, pairComparator, serializer1, serializer2, spillHeadCopy
Constructor and Description |
---|
NonReusingMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType outerJoinType,
MutableObjectIterator<T1> input1,
MutableObjectIterator<T2> input2,
TypeSerializer<T1> serializer1,
TypeComparator<T1> comparator1,
TypeSerializer<T2> serializer2,
TypeComparator<T2> comparator2,
TypePairComparator<T1,T2> pairComparator,
MemoryManager memoryManager,
IOManager ioManager,
int numMemoryPages,
AbstractInvokable parentTask) |
Modifier and Type | Method and Description |
---|---|
protected <T> T |
createCopy(TypeSerializer<T> serializer,
T value,
T reuse)
Copies an instance of the given type, potentially reusing the object passed as the reuse
parameter, which may be null.
|
protected <T> KeyGroupedIterator<T> |
createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
callWithNextKey
abort, close, crossMatchingGroup, open
public NonReusingMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType outerJoinType, MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask) throws MemoryAllocationException
MemoryAllocationException
protected <T> KeyGroupedIterator<T> createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
createKeyGroupedIterator
in class AbstractMergeIterator<T1,T2,O>
protected <T> T createCopy(TypeSerializer<T> serializer, T value, T reuse)
AbstractMergeIterator
createCopy
in class AbstractMergeIterator<T1,T2,O>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.