alluxio.job.plan.transform.format.csv

Class CsvReader

java.lang.Object

alluxio.job.plan.transform.format.csv.CsvReader

All Implemented Interfaces:

TableReader, Closeable, AutoCloseable

public final class CsvReader
extends Object
implements TableReader

A reader for reading CsvRow.

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

create

public static CsvReader create(AlluxioURI uri,
                               PartitionInfo pInfo)
                        throws IOException

Creates a CSV reader.

Specified by:

create in interface TableReader

Parameters:

uri - the URI to the input

pInfo - the partition info

Returns:

the reader

Throws:

IOException - when failed to create the reader

getSchema

public TableSchema getSchema()
                      throws IOException

Specified by:

getSchema in interface TableReader

Returns:

the table schema

Throws:

IOException - when failed to read the 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