org.apache.hive.hcatalog.data.transfer.impl

Class HCatInputFormatReader

java.lang.Object

org.apache.hive.hcatalog.data.transfer.HCatReader

org.apache.hive.hcatalog.data.transfer.impl.HCatInputFormatReader

public class HCatInputFormatReader
extends HCatReader

This reader reads via HCatInputFormat

Field Summary

Fields inherited from class org.apache.hive.hcatalog.data.transfer.HCatReader

conf, info, re, sp

Constructor Summary

Constructors

Constructor and Description
HCatInputFormatReader(ReadEntity info, Map<String,String> config)
HCatInputFormatReader(ReaderContext context, int slaveNumber, StateProvider sp)

Method Summary

Methods

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.
Iterator<HCatRecord>	read() This should be called at slave nodes to read HCatRecords

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HCatInputFormatReader

public HCatInputFormatReader(ReaderContext context,
                     int slaveNumber,
                     StateProvider sp)

HCatInputFormatReader

public HCatInputFormatReader(ReadEntity info,
                     Map<String,String> config)

Method Detail

prepareRead

public ReaderContext prepareRead()
                          throws HCatException

Description copied from class: HCatReader

This should be called at master node to obtain ReaderContext which then should be serialized and sent to slave nodes.

Specified by:

prepareRead in class HCatReader

Returns:

ReaderContext

Throws:

HCatException

read

public Iterator<HCatRecord> read()
                          throws HCatException

Description copied from class: HCatReader

This should be called at slave nodes to read HCatRecords

Specified by:

read in class HCatReader

Returns:

Iterator of HCatRecord

Throws:

HCatException