com.asakusafw.directio.hive.orc

Class OrcFileInput<T>

java.lang.Object

com.asakusafw.directio.hive.orc.OrcFileInput<T>

Type Parameters:

T - the data model type

All Implemented Interfaces:

ModelInput<T>, Closeable, AutoCloseable

public class OrcFileInput<T>
extends Object
implements ModelInput<T>

An implementation of ModelInput for reading ORCFile.

Since:

0.7.0

Constructor Summary

Constructors

Constructor and Description
OrcFileInput(DataModelDescriptor descriptor, DataModelMapping configuration, org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.fs.Path path, long offset, long fragmentSize, Counter counter) Creates a new instance.
OrcFileInput(DataModelDescriptor descriptor, org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.fs.Path path, long offset, long fragmentSize, Counter counter) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	readTo(T model) Reads contents and write them into the target data model object.

Methods inherited from class java.lang.Object

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

Constructor Detail

OrcFileInput

public OrcFileInput(DataModelDescriptor descriptor,
                    org.apache.hadoop.fs.FileSystem fileSystem,
                    org.apache.hadoop.fs.Path path,
                    long offset,
                    long fragmentSize,
                    Counter counter)

Creates a new instance.

Parameters:

descriptor - the target data model descriptor

fileSystem - the file system to open the target path

path - the path to the target file

offset - starting stream offset

fragmentSize - suggested fragment bytes count

counter - the current counter

OrcFileInput

public OrcFileInput(DataModelDescriptor descriptor,
                    DataModelMapping configuration,
                    org.apache.hadoop.fs.FileSystem fileSystem,
                    org.apache.hadoop.fs.Path path,
                    long offset,
                    long fragmentSize,
                    Counter counter)

Creates a new instance.

Parameters:

descriptor - the target data model descriptor

configuration - the DataModelDriver configuration

fileSystem - the file system to open the target path

path - the path to the target file

offset - starting stream offset

fragmentSize - suggested fragment bytes count

counter - the current counter

Method Detail

readTo

public boolean readTo(T model)
               throws IOException

Description copied from interface: ModelInput

Reads contents and write them into the target data model object. The target data model object will be changed even if the next data does not exist.

Specified by:

readTo in interface ModelInput<T>

Parameters:

model - the target data model object

Returns:

true if the next data was successfully read, or false if there is no any more

Throws:

IOException - if error occurred while reading the next data

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException