public interface RowKeyJoin
Modifier and Type | Interface and Description |
---|---|
static class |
RowKeyJoin.RowKeyJoinState
Enum for RowKeyJoin internal state.
|
Modifier and Type | Method and Description |
---|---|
AbstractRecordBatch.BatchState |
getBatchState()
Get the current BatchState (this is useful when performing row key join)
|
RowKeyJoin.RowKeyJoinState |
getRowKeyJoinState()
Get the current RowKeyJoinState.
|
boolean |
hasRowKeyBatch()
Is the next batch of row keys ready to be returned
|
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)
|
boolean hasRowKeyBatch()
org.apache.commons.lang3.tuple.Pair<ValueVector,Integer> nextRowKeyBatch()
AbstractRecordBatch.BatchState getBatchState()
void setBatchState(AbstractRecordBatch.BatchState newState)
newState
- void setRowKeyJoinState(RowKeyJoin.RowKeyJoinState newState)
newState
- RowKeyJoin.RowKeyJoinState getRowKeyJoinState()
Copyright © 1970 The Apache Software Foundation. All rights reserved.