public class TupleBatch extends Object
beginning row
is the first row contained in this batch; if it equals "1" then it is the
first row of the tuple source, otherwise this is a batch of intermediate
tuples. The ending row
is the last row contained in
this tuple batch; it is equal to the beginning row plus the
number of rows
contained in this batch, minus one.Modifier and Type | Field and Description |
---|---|
static byte |
ITERATION_TERMINATED |
static byte |
NOT_TERMINATED |
static byte |
TERMINATED |
protected List<List<?>> |
tuples |
Constructor and Description |
---|
TupleBatch()
Required to honor Externalizable contract
|
TupleBatch(long beginRow,
List<?>[] tuples)
Constructor
|
TupleBatch(long beginRow,
List<? extends List<?>> listOfTupleLists)
Constructor
|
Modifier and Type | Method and Description |
---|---|
boolean |
containsRow(long row) |
List<?>[] |
getAllTuples()
Get all tuples
|
long |
getBeginRow()
Return the number of the first row of the tuple source that is
contained in this batch (one-based).
|
long |
getEndRow()
Return number of the last row of the tuple source that is contained in
this batch (one-based).
|
int |
getRowCount()
Return the number of rows contained in this tuple batch
|
byte |
getTermination() |
boolean |
getTerminationFlag()
Check whether this batch is the last in a series of batches.
|
List<?> |
getTuple(long rowIndex)
Return the tuple at the given index (one-based).
|
List<List<?>> |
getTuples() |
void |
setRowOffset(long rowOffset) |
void |
setTermination(byte val) |
void |
setTerminationFlag(boolean terminationFlag)
Set whether this batch is the last in a series of batches.
|
String |
toString()
Return a String describing this object
|
public static final byte NOT_TERMINATED
public static final byte TERMINATED
public static final byte ITERATION_TERMINATED
public TupleBatch()
public TupleBatch(long beginRow, List<?>[] tuples)
beginRow
- indicates the row of the tuple source which is the
first row contained in this batchtuples
- array of List objects, each of which is
a single tuplepublic long getBeginRow()
public long getEndRow()
public int getRowCount()
public List<?> getTuple(long rowIndex)
public List<?>[] getAllTuples()
public boolean getTerminationFlag()
public void setTerminationFlag(boolean terminationFlag)
terminationFlag
- True if lastpublic void setTermination(byte val)
public byte getTermination()
public boolean containsRow(long row)
public String toString()
public void setRowOffset(long rowOffset)
Copyright © 2018 JBoss by Red Hat. All rights reserved.