Package | Description |
---|---|
com.asakusafw.directio.hive.parquet |
Parquet file format bridge between Asakusa and Hive.
|
com.asakusafw.directio.hive.parquet.v1 |
Parquet format bridge for Hive v1.
|
com.asakusafw.directio.hive.parquet.v2 |
Parquet format bridge for Hive v2.
|
Modifier and Type | Class and Description |
---|---|
class |
ParquetFileFormat<T>
An implementation of
DataFormat for Parquet file. |
Modifier and Type | Method and Description |
---|---|
abstract List<DirectInputFragment> |
Compatibility.computeInputFragments(AbstractParquetFileFormat<?> format,
StripedDataFormat.InputContext context)
delegate from
StripedDataFormat.computeInputFragments(InputContext) . |
abstract <T> ModelInput<T> |
Compatibility.createInput(AbstractParquetFileFormat<T> format,
Class<? extends T> dataType,
org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.fs.Path path,
long offset,
long fragmentSize,
Counter counter)
delegate from
createInput(Class, FileSystem, Path, long, long, Counter) . |
abstract <T> ModelOutput<T> |
Compatibility.createOutput(AbstractParquetFileFormat<T> format,
Class<? extends T> dataType,
org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.fs.Path path,
Counter counter)
delegate from
createOutput(Class, FileSystem, Path, Counter) . |
Modifier and Type | Method and Description |
---|---|
List<DirectInputFragment> |
CompatibilityV1.computeInputFragments(AbstractParquetFileFormat<?> format,
StripedDataFormat.InputContext context) |
<T> ModelInput<T> |
CompatibilityV1.createInput(AbstractParquetFileFormat<T> format,
Class<? extends T> dataType,
org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.fs.Path path,
long offset,
long fragmentSize,
Counter counter) |
<T> ModelOutput<T> |
CompatibilityV1.createOutput(AbstractParquetFileFormat<T> format,
Class<? extends T> dataType,
org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.fs.Path path,
Counter counter) |
Modifier and Type | Method and Description |
---|---|
List<DirectInputFragment> |
CompatibilityV2.computeInputFragments(AbstractParquetFileFormat<?> format,
StripedDataFormat.InputContext context) |
<T> ModelInput<T> |
CompatibilityV2.createInput(AbstractParquetFileFormat<T> format,
Class<? extends T> dataType,
org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.fs.Path path,
long offset,
long fragmentSize,
Counter counter) |
<T> ModelOutput<T> |
CompatibilityV2.createOutput(AbstractParquetFileFormat<T> format,
Class<? extends T> dataType,
org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.fs.Path path,
Counter counter) |
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.