com.splicemachine.derby.stream.iterator

Class GetNLJoinIterator

java.lang.Object

com.splicemachine.derby.stream.iterator.GetNLJoinIterator

All Implemented Interfaces:

java.util.concurrent.Callable<Pair<OperationContext,java.util.Iterator<ExecRow>>>

Direct Known Subclasses:

GetNLJoinAntiIterator, GetNLJoinInnerIterator, GetNLJoinLeftOuterIterator, GetNLJoinOneRowIterator

public abstract class GetNLJoinIterator
extends java.lang.Object
implements java.util.concurrent.Callable<Pair<OperationContext,java.util.Iterator<ExecRow>>>

Created by jyuan on 10/10/16.

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecRow	locatedRow
protected OperationContext	operationContext

Constructor Summary

Constructors

Constructor and Description
GetNLJoinIterator()
GetNLJoinIterator(OperationContext operationContext, ExecRow locatedRow)

Method Summary

Modifier and Type	Method and Description
abstract Pair<OperationContext,java.util.Iterator<ExecRow>>	call()
static GetNLJoinIterator	makeGetNLJoinIterator(NLJoinFunction.JoinType joinType, OperationContext operationContext, ExecRow locatedRow)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

locatedRow

protected ExecRow locatedRow

operationContext

protected OperationContext operationContext

Constructor Detail

GetNLJoinIterator

public GetNLJoinIterator()

GetNLJoinIterator

public GetNLJoinIterator(OperationContext operationContext,
                         ExecRow locatedRow)

Method Detail

call

public abstract Pair<OperationContext,java.util.Iterator<ExecRow>> call()
                                                                 throws java.lang.Exception

Specified by:

call in interface java.util.concurrent.Callable<Pair<OperationContext,java.util.Iterator<ExecRow>>>

Throws:

java.lang.Exception

makeGetNLJoinIterator

public static GetNLJoinIterator makeGetNLJoinIterator(NLJoinFunction.JoinType joinType,
                                                      OperationContext operationContext,
                                                      ExecRow locatedRow)