public class MultiMergeJoinData extends BaseStepData implements StepDataInterface
| Modifier and Type | Class and Description |
|---|---|
static class |
MultiMergeJoinData.QueueComparator |
static class |
MultiMergeJoinData.QueueEntry |
BaseStepData.StepExecutionStatus| Modifier and Type | Field and Description |
|---|---|
int[] |
drainIndices |
Object[][] |
dummy |
int[][] |
keyNrs |
RowMetaInterface[] |
metas |
boolean |
optional |
RowMetaInterface |
outputRowMeta |
PriorityQueue<MultiMergeJoinData.QueueEntry> |
queue |
MultiMergeJoinData.QueueEntry[] |
queueEntries |
List<List<Object[]>> |
results |
int[] |
rowLengths |
Object[][] |
rows |
RowSet[] |
rowSets |
| Constructor and Description |
|---|
MultiMergeJoinData()
Default initializer
|
getStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, isStopped, setStatusclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, setStatuspublic Object[][] rows
public RowMetaInterface[] metas
public RowMetaInterface outputRowMeta
public Object[][] dummy
public PriorityQueue<MultiMergeJoinData.QueueEntry> queue
public boolean optional
public int[][] keyNrs
public int[] drainIndices
public RowSet[] rowSets
public MultiMergeJoinData.QueueEntry[] queueEntries
public int[] rowLengths
Copyright © 2018 Hitachi Vantara. All rights reserved.