alluxio.job.plan.transform.format.parquet

Class ParquetReader

java.lang.Object

alluxio.job.plan.transform.format.parquet.ParquetReader

All Implemented Interfaces:

TableReader, Closeable, AutoCloseable

public final class ParquetReader
extends Object
implements TableReader

A reader for reading ParquetRow.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the reader, which will close the underlying stream.
static ParquetReader	create(AlluxioURI uri) Creates a parquet reader.
org.apache.parquet.hadoop.metadata.ParquetMetadata	getMetadata()
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 ParquetReader create(AlluxioURI uri)
                            throws IOException

Creates a parquet reader.

Parameters:

uri - the URI to the input

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

getMetadata

public org.apache.parquet.hadoop.metadata.ParquetMetadata getMetadata()

Returns:

the Parquet metadata

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