com.asakusafw.directio.hive.parquet

Class ParquetFileFormat<T>

java.lang.Object

org.apache.hadoop.conf.Configured

com.asakusafw.runtime.directio.hadoop.HadoopFileFormat<T>

com.asakusafw.directio.hive.parquet.AbstractParquetFileFormat<T>

com.asakusafw.directio.hive.parquet.ParquetFileFormat<T>

Type Parameters:

T - the data model type

All Implemented Interfaces:

TableInfo.Provider, DataFormat<T>, FragmentableDataFormat<T>, StripedDataFormat<T>, org.apache.hadoop.conf.Configurable

public class ParquetFileFormat<T>
extends AbstractParquetFileFormat<T>

An implementation of DataFormat for Parquet file.

Since:

0.7.0

Nested Class Summary

Nested classes/interfaces inherited from interface com.asakusafw.runtime.directio.hadoop.StripedDataFormat

StripedDataFormat.InputContext

Constructor Summary

Constructors

Constructor and Description
ParquetFileFormat(String tableName, ParquetFormatConfiguration configuration, DataModelDescriptor descriptor) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
DataModelDescriptor	getDataModelDescriptor() Returns the target data model descriptor.
ParquetFormatConfiguration	getFormatConfiguration() Returns the format configuration.
String	getTableName() Returns the table name.

Methods inherited from class com.asakusafw.directio.hive.parquet.AbstractParquetFileFormat

computeInputFragments, createInput, createOutput, getSchema, getSupportedType

Methods inherited from class com.asakusafw.runtime.directio.hadoop.HadoopFileFormat

createInput

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.asakusafw.runtime.directio.FragmentableDataFormat

getMinimumFragmentSize, getPreferredFragmentSize

Constructor Detail

ParquetFileFormat

public ParquetFileFormat(String tableName,
                         ParquetFormatConfiguration configuration,
                         DataModelDescriptor descriptor)

Creates a new instance.

Parameters:

tableName - the target table name

configuration - the format configuration

descriptor - the data model descriptor

Method Detail

getTableName

public String getTableName()

Description copied from class: AbstractParquetFileFormat

Returns the table name.

Specified by:

getTableName in class AbstractParquetFileFormat<T>

Returns:

the table name

getDataModelDescriptor

public DataModelDescriptor getDataModelDescriptor()

Description copied from class: AbstractParquetFileFormat

Returns the target data model descriptor.

Specified by:

getDataModelDescriptor in class AbstractParquetFileFormat<T>

Returns:

the target data model descriptor

getFormatConfiguration

public ParquetFormatConfiguration getFormatConfiguration()

Description copied from class: AbstractParquetFileFormat

Returns the format configuration.

Specified by:

getFormatConfiguration in class AbstractParquetFileFormat<T>

Returns:

the format configuration