com.actian.dataflow.hive.shims

Interface RecordReaderShim

public interface RecordReaderShim

Shim interface for a Hive record reader.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes any resources associated with the underlying file.
long	getRowNumber() Returns the row number of the current row.
boolean	hasNext() Returns true if more records are available from the reader.
void	processNext() Processes the next available record.

Method Detail

hasNext

boolean hasNext()
                throws IOException

Returns true if more records are available from the reader.

Returns:

true for more records available; false otherwise

Throws:

IOException - thrown if an I/O error occurs accessing the underlying file

processNext

void processNext()
                 throws IOException

Processes the next available record. The record is parsed and the data values are pushed to the target record settable.

Throws:

IOException - thrown if an I/O error occurs accessing the underlying file

getRowNumber

long getRowNumber()
                  throws IOException

Returns the row number of the current row. This number is guaranteed to be unique within a file.

Returns:

row number

Throws:

IOException - thrown if an I/O error occurs accessing the underlying file

close

void close()
           throws IOException

Closes any resources associated with the underlying file. Any further reader access will cause an exception to be thrown.

Throws:

IOException - thrown if an I/O error occurs accessing the underlying file