public class PTFRowContainer<Row extends List<Object>> extends RowContainer<Row>
getAt(i)
.
It extends RowContainer behavior in the following ways:
blockSize
currentReadBlockStartRow,blockSize
. So if a row is requested in this span,
we don't need to read rows from disk.
getAt
leaves the Container in the same state as a
next
call; so a getAt and next calls can be interspersed.
Modifier and Type | Class and Description |
---|---|
static class |
PTFRowContainer.PTFHiveSequenceFileOutputFormat<K,V> |
static class |
PTFRowContainer.PTFSequenceFileInputFormat<K,V> |
static class |
PTFRowContainer.PTFSequenceFileRecordReader<K,V> |
AbstractRowContainer.RowIterator<ROW>
LOG
Constructor and Description |
---|
PTFRowContainer(int bs,
org.apache.hadoop.conf.Configuration jc,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
addRow(Row t)
add a row into the RowContainer
|
void |
clearRows()
Remove all elements in the RowContainer.
|
void |
close() |
static TableDesc |
createTableDesc(StructObjectInspector oI) |
Row |
first() |
Row |
getAt(int rowIdx) |
Row |
next() |
copyToDFSDirecory, endOfCurrentReadBlock, getAddCursor, getBlockSize, getCurrentReadBlockSize, getInputSplits, getLastActualSplit, getReadBlockRow, getRecordWriter, hasRows, isSingleRow, nextBlock, resetCurrentReadBlockToFirstReadBlock, resetReadBlocks, rowCount, rowIter, setKeyObject, setReaderAtSplit, setSerDe, setTableDesc, setupWriter, setWriteBlockAsReadBlock, willSpill
public PTFRowContainer(int bs, org.apache.hadoop.conf.Configuration jc, org.apache.hadoop.mapred.Reporter reporter) throws HiveException
HiveException
public void addRow(Row t) throws HiveException
AbstractRowContainer
addRow
in interface AbstractRowContainer<Row extends List<Object>>
addRow
in class RowContainer<Row extends List<Object>>
t
- rowHiveException
public Row first() throws HiveException
first
in interface AbstractRowContainer.RowIterator<Row extends List<Object>>
first
in class RowContainer<Row extends List<Object>>
HiveException
public Row next() throws HiveException
next
in interface AbstractRowContainer.RowIterator<Row extends List<Object>>
next
in class RowContainer<Row extends List<Object>>
HiveException
public void clearRows() throws HiveException
RowContainer
clearRows
in interface AbstractRowContainer<Row extends List<Object>>
clearRows
in class RowContainer<Row extends List<Object>>
HiveException
public void close() throws HiveException
close
in class RowContainer<Row extends List<Object>>
HiveException
public Row getAt(int rowIdx) throws HiveException
HiveException
public static TableDesc createTableDesc(StructObjectInspector oI)
Copyright © 2017 The Apache Software Foundation. All rights reserved.