org.apache.drill.exec.physical.impl.join

Class RowKeyJoinBatch

java.lang.Object

org.apache.drill.exec.record.AbstractRecordBatch<RowKeyJoinPOP>

org.apache.drill.exec.physical.impl.join.RowKeyJoinBatch

All Implemented Interfaces:

AutoCloseable, Iterable<VectorWrapper<?>>, RowKeyJoin, CloseableRecordBatch, RecordBatch, VectorAccessible

public class RowKeyJoinBatch
extends AbstractRecordBatch<RowKeyJoinPOP>
implements RowKeyJoin

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.record.AbstractRecordBatch

AbstractRecordBatch.BatchState

Nested classes/interfaces inherited from interface org.apache.drill.exec.physical.impl.join.RowKeyJoin

RowKeyJoin.RowKeyJoinState

Nested classes/interfaces inherited from interface org.apache.drill.exec.record.RecordBatch

RecordBatch.IterOutcome

Field Summary

Fields inherited from class org.apache.drill.exec.record.AbstractRecordBatch

batchStatsContext, container, context, oContext, popConfig, state, stats, unionTypeEnabled

Fields inherited from interface org.apache.drill.exec.record.RecordBatch

MAX_BATCH_ROW_COUNT

Constructor Summary

Constructors

Constructor and Description
RowKeyJoinBatch(RowKeyJoinPOP config, FragmentContext context, RecordBatch left, RecordBatch right)

Method Summary

Modifier and Type	Method and Description
protected void	buildSchema()
protected void	cancelIncoming()
void	close()
void	dump() Perform dump of this batch's state to logs.
AbstractRecordBatch.BatchState	getBatchState() Get the current BatchState (this is useful when performing row key join)
int	getRecordCount() Get the number of records.
RowKeyJoin.RowKeyJoinState	getRowKeyJoinState() Get the current RowKeyJoinState.
SelectionVector2	getSelectionVector2()
SelectionVector4	getSelectionVector4()
boolean	hasRowKeyBatch() Is the next batch of row keys ready to be returned
RecordBatch.IterOutcome	innerNext()
org.apache.commons.lang3.tuple.Pair<ValueVector,Integer>	nextRowKeyBatch() Get the next batch of row keys
void	setBatchState(AbstractRecordBatch.BatchState newState) Set the BatchState (this is useful when performing row key join)
void	setRowKeyJoinState(RowKeyJoin.RowKeyJoinState newState) Set the RowKeyJoinState (this is useful for maintaining state for row key join algorithm)

Methods inherited from class org.apache.drill.exec.record.AbstractRecordBatch

cancel, checkContinue, getContainer, getContext, getOutgoingContainer, getPopConfig, getRecordBatchStatsContext, getSchema, getValueAccessorById, getValueVectorId, getWritableBatch, isRecordBatchStatsLoggingEnabled, iterator, next, next, next, schemaChangeException, schemaChangeException

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

RowKeyJoinBatch

public RowKeyJoinBatch(RowKeyJoinPOP config,
                       FragmentContext context,
                       RecordBatch left,
                       RecordBatch right)
                throws OutOfMemoryException

Throws:

OutOfMemoryException

Method Detail

getRecordCount

public int getRecordCount()

Description copied from interface: VectorAccessible

Get the number of records.

Specified by:

getRecordCount in interface VectorAccessible

Returns:

number of records

getSelectionVector2

public SelectionVector2 getSelectionVector2()

Specified by:

getSelectionVector2 in interface VectorAccessible

Overrides:

getSelectionVector2 in class AbstractRecordBatch<RowKeyJoinPOP>

getSelectionVector4

public SelectionVector4 getSelectionVector4()

Specified by:

getSelectionVector4 in interface VectorAccessible

Overrides:

getSelectionVector4 in class AbstractRecordBatch<RowKeyJoinPOP>

buildSchema

protected void buildSchema()

Overrides:

buildSchema in class AbstractRecordBatch<RowKeyJoinPOP>

innerNext

public RecordBatch.IterOutcome innerNext()

Specified by:

innerNext in class AbstractRecordBatch<RowKeyJoinPOP>

hasRowKeyBatch

public boolean hasRowKeyBatch()

Description copied from interface: RowKeyJoin

Is the next batch of row keys ready to be returned

Specified by:

hasRowKeyBatch in interface RowKeyJoin

Returns:

True if ready, false if not

nextRowKeyBatch

public org.apache.commons.lang3.tuple.Pair<ValueVector,Integer> nextRowKeyBatch()

Description copied from interface: RowKeyJoin

Get the next batch of row keys

Specified by:

nextRowKeyBatch in interface RowKeyJoin

Returns:

a Pair whose left element is the ValueVector containing the row keys, right element is the number of row keys in this batch

getBatchState

public AbstractRecordBatch.BatchState getBatchState()

Description copied from interface: RowKeyJoin

Get the current BatchState (this is useful when performing row key join)

Specified by:

getBatchState in interface RowKeyJoin

setBatchState

public void setBatchState(AbstractRecordBatch.BatchState newState)

Description copied from interface: RowKeyJoin

Set the BatchState (this is useful when performing row key join)

Specified by:

setBatchState in interface RowKeyJoin

setRowKeyJoinState

public void setRowKeyJoinState(RowKeyJoin.RowKeyJoinState newState)

Description copied from interface: RowKeyJoin

Set the RowKeyJoinState (this is useful for maintaining state for row key join algorithm)

Specified by:

setRowKeyJoinState in interface RowKeyJoin

getRowKeyJoinState

public RowKeyJoin.RowKeyJoinState getRowKeyJoinState()

Description copied from interface: RowKeyJoin

Get the current RowKeyJoinState.

Specified by:

getRowKeyJoinState in interface RowKeyJoin

cancelIncoming

protected void cancelIncoming()

Specified by:

cancelIncoming in class AbstractRecordBatch<RowKeyJoinPOP>

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractRecordBatch<RowKeyJoinPOP>

dump

public void dump()

Description copied from interface: RecordBatch

Perform dump of this batch's state to logs.

Specified by:

dump in interface RecordBatch