public class RowContainer<ROW extends java.util.List<java.lang.Object>> extends AbstractRowContainer<ROW>
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
RowContainer(Configuration jc,
Reporter reporter) |
RowContainer(int bs,
Configuration jc,
Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
add(ROW t) |
void |
clear()
Remove all elements in the RowContainer.
|
protected void |
close() |
void |
copyToDFSDirecory(FileSystem destFs,
Path destPath) |
protected boolean |
endOfCurrentReadBlock() |
ROW |
first() |
protected int |
getAddCursor() |
protected int |
getBlockSize() |
protected int |
getCurrentReadBlockSize() |
protected InputSplit[] |
getInputSplits() |
protected ROW |
getReadBlockRow(int rowOffset) |
protected FileSinkOperator.RecordWriter |
getRecordWriter() |
ROW |
next() |
protected boolean |
nextBlock(int readIntoOffset) |
protected void |
resetCurrentReadBlockToFirstReadBlock() |
protected void |
resetReadBlocks() |
void |
setKeyObject(java.util.List<java.lang.Object> dummyKey) |
protected org.apache.hadoop.mapred.RecordReader |
setReaderAtSplit(int splitNum) |
void |
setSerDe(SerDe sd,
ObjectInspector oi) |
void |
setTableDesc(TableDesc tblDesc) |
protected void |
setupWriter() |
protected void |
setWriteBlockAsReadBlock() |
long |
size()
Get the number of elements in the RowContainer.
|
protected boolean |
willSpill() |
public RowContainer(Configuration jc, Reporter reporter) throws HiveException
HiveException
public RowContainer(int bs, Configuration jc, Reporter reporter) throws HiveException
HiveException
public void setSerDe(SerDe sd, ObjectInspector oi)
public void add(ROW t) throws HiveException
add
in class AbstractRowContainer<ROW extends java.util.List<java.lang.Object>>
HiveException
public ROW first() throws HiveException
first
in class AbstractRowContainer<ROW extends java.util.List<java.lang.Object>>
HiveException
public ROW next() throws HiveException
next
in class AbstractRowContainer<ROW extends java.util.List<java.lang.Object>>
HiveException
public long size()
size
in class AbstractRowContainer<ROW extends java.util.List<java.lang.Object>>
protected boolean nextBlock(int readIntoOffset) throws HiveException
HiveException
public void copyToDFSDirecory(FileSystem destFs, Path destPath) throws java.io.IOException, HiveException
java.io.IOException
HiveException
public void clear() throws HiveException
clear
in class AbstractRowContainer<ROW extends java.util.List<java.lang.Object>>
HiveException
public void setKeyObject(java.util.List<java.lang.Object> dummyKey)
public void setTableDesc(TableDesc tblDesc)
protected int getAddCursor()
protected final boolean willSpill()
protected int getBlockSize()
protected void setupWriter() throws HiveException
HiveException
protected FileSinkOperator.RecordWriter getRecordWriter()
protected InputSplit[] getInputSplits()
protected boolean endOfCurrentReadBlock()
protected int getCurrentReadBlockSize()
protected void setWriteBlockAsReadBlock()
protected org.apache.hadoop.mapred.RecordReader setReaderAtSplit(int splitNum) throws java.io.IOException
java.io.IOException
protected ROW getReadBlockRow(int rowOffset)
protected void resetCurrentReadBlockToFirstReadBlock()
protected void resetReadBlocks()
protected void close() throws HiveException
HiveException
Copyright © 2012 The Apache Software Foundation