com.actian.dataflow.hive.shims

Class ParquetSplitsRecordReaderShimImpl

java.lang.Object

com.actian.dataflow.hive.shims.ParquetSplitsRecordReaderShimImpl

All Implemented Interfaces:

RecordReaderShim

public class ParquetSplitsRecordReaderShimImpl
extends Object
implements RecordReaderShim

Shim interface for a Hive Parquet record reader.

Constructor Summary

Constructors

Constructor and Description
ParquetSplitsRecordReaderShimImpl(ParquetFileReader parquetFileReader, MessageType schema, List<Integer> indexes, List<com.actian.dataflow.hive.shims.ParquetDecoder> decoders)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetSplitsRecordReaderShimImpl

public ParquetSplitsRecordReaderShimImpl(ParquetFileReader parquetFileReader,
                                 MessageType schema,
                                 List<Integer> indexes,
                                 List<com.actian.dataflow.hive.shims.ParquetDecoder> decoders)
                                  throws IOException

Throws:

IOException

Method Detail

hasNext

public boolean hasNext()
                throws IOException

Description copied from interface: RecordReaderShim

Returns true if more records are available from the reader.

Specified by:

hasNext in interface RecordReaderShim

Returns:

true for more records available; false otherwise

Throws:

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

processNext

public void processNext()
                 throws IOException

Description copied from interface: RecordReaderShim

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

Specified by:

processNext in interface RecordReaderShim

Throws:

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

getRowNumber

public long getRowNumber()
                  throws IOException

Description copied from interface: RecordReaderShim

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

Specified by:

getRowNumber in interface RecordReaderShim

Returns:

row number

Throws:

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

close

public void close()
           throws IOException

Description copied from interface: RecordReaderShim

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

Specified by:

close in interface RecordReaderShim

Throws:

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