alluxio.job.plan.transform.format

Interface TableReader

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

CsvReader, OrcReader, ParquetReader

public interface TableReader
extends Closeable

A reader for reading rows in a table.

Method Summary

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

Method Detail

create

static TableReader create(AlluxioURI uri,
                          PartitionInfo pInfo)
                   throws IOException

Parameters:

uri - the URI to the input

pInfo - the partition info from catalog service

Returns:

the reader for the input

Throws:

IOException - when failed to create the reader

getSchema

TableSchema getSchema()
               throws IOException

Returns:

the table schema

Throws:

IOException - when failed to read the schema

read

TableRow read()
       throws IOException

Returns:

the next row or null if there are no more rows

Throws:

IOException - when read fails

close

void close()
    throws IOException

Closes the reader, which will close the underlying stream.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException - when failing to close the underlying stream