public class HCatInputFormatReader extends HCatReader
HCatInputFormatconf, info, re, sp| Constructor and Description |
|---|
HCatInputFormatReader(InputSplit split,
Configuration config,
StateProvider sp) |
HCatInputFormatReader(ReadEntity info,
java.util.Map<java.lang.String,java.lang.String> config) |
| Modifier and Type | Method and Description |
|---|---|
ReaderContext |
prepareRead()
This should be called at master node to obtain
ReaderContext which
then should be serialized and sent to slave nodes. |
java.util.Iterator<HCatRecord> |
read()
This should be called at slave nodes to read
HCatRecords |
getConfpublic HCatInputFormatReader(InputSplit split,
Configuration config,
StateProvider sp)
public HCatInputFormatReader(ReadEntity info, java.util.Map<java.lang.String,java.lang.String> config)
public ReaderContext prepareRead() throws HCatException
HCatReaderReaderContext which
then should be serialized and sent to slave nodes.prepareRead in class HCatReaderReaderContextHCatExceptionpublic java.util.Iterator<HCatRecord> read() throws HCatException
HCatReaderHCatRecordsread in class HCatReaderIterator of HCatRecordHCatExceptionCopyright © 2012 The Apache Software Foundation