alluxio.job.plan.transform.format.orc

Class OrcReader

java.lang.Object

alluxio.job.plan.transform.format.orc.OrcReader

All Implemented Interfaces:

TableReader, Closeable, AutoCloseable

public final class OrcReader
extends Object
implements TableReader

The Orc reader.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the reader, which will close the underlying stream.
static OrcReader	create(AlluxioURI uri)
TableSchema	getSchema()
TableRow	read()

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.job.plan.transform.format.TableReader

create

Method Detail

create

public static OrcReader create(AlluxioURI uri)
                        throws IOException

Parameters:

uri - the alluxio uri of the orc file

Returns:

new instance of OrcReader

Throws:

IOException

getSchema

public TableSchema getSchema()

Specified by:

getSchema in interface TableReader

Returns:

the table schema

read

public TableRow read()
              throws IOException

Specified by:

read in interface TableReader

Returns:

the next row or null if there are no more rows

Throws:

IOException - when read fails

close

public void close()
           throws IOException

Description copied from interface: TableReader

Closes the reader, which will close the underlying stream.

Specified by:

close in interface TableReader

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException - when failing to close the underlying stream