Package | Description |
---|---|
com.asakusafw.directio.hive.orc |
ORCFile format bridge between Asakusa and Hive.
|
com.asakusafw.directio.hive.orc.v1 |
ORCFile format bridge for Hive v1.
|
com.asakusafw.directio.hive.orc.v2 |
ORCFile format bridge for Hive v2.
|
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.
|
com.asakusafw.runtime.directio |
Direct I/O access from Asakusa Framework.
|
com.asakusafw.runtime.directio.hadoop |
Direct I/O access for Hadoop Environment.
|
com.asakusafw.runtime.directio.keepalive |
Keep-alive utilities for Direct I/O access.
|
Modifier and Type | Method and Description |
---|---|
abstract List<DirectInputFragment> |
Compatibility.computeInputFragments(AbstractOrcFileFormat<?> format,
StripedDataFormat.InputContext context)
delegate from
StripedDataFormat.computeInputFragments(InputContext) . |
List<DirectInputFragment> |
AbstractOrcFileFormat.computeInputFragments(StripedDataFormat.InputContext context) |
Modifier and Type | Method and Description |
---|---|
List<DirectInputFragment> |
CompatibilityV1.computeInputFragments(AbstractOrcFileFormat<?> format,
StripedDataFormat.InputContext context) |
Modifier and Type | Method and Description |
---|---|
List<DirectInputFragment> |
CompatibilityV2.computeInputFragments(AbstractOrcFileFormat<?> format,
StripedDataFormat.InputContext context) |
Modifier and Type | Method and Description |
---|---|
abstract List<DirectInputFragment> |
Compatibility.computeInputFragments(AbstractParquetFileFormat<?> format,
StripedDataFormat.InputContext context)
delegate from
StripedDataFormat.computeInputFragments(InputContext) . |
List<DirectInputFragment> |
AbstractParquetFileFormat.computeInputFragments(StripedDataFormat.InputContext context) |
Modifier and Type | Method and Description |
---|---|
List<DirectInputFragment> |
CompatibilityV1.computeInputFragments(AbstractParquetFileFormat<?> format,
StripedDataFormat.InputContext context) |
Modifier and Type | Method and Description |
---|---|
List<DirectInputFragment> |
CompatibilityV2.computeInputFragments(AbstractParquetFileFormat<?> format,
StripedDataFormat.InputContext context) |
Modifier and Type | Method and Description |
---|---|
<T> List<DirectInputFragment> |
DirectDataSource.findInputFragments(DataDefinition<T> definition,
String basePath,
ResourcePattern resourcePattern)
Collects input fragments about target resources.
|
Modifier and Type | Method and Description |
---|---|
<T> ModelInput<T> |
DirectDataSource.openInput(DataDefinition<T> definition,
DirectInputFragment fragment,
Counter counter)
Opens a fragment for input.
|
Modifier and Type | Method and Description |
---|---|
DirectInputFragment |
BlockMap.get(long start,
long end)
Returns
DirectInputFragment for the range. |
Modifier and Type | Method and Description |
---|---|
List<DirectInputFragment> |
StripedDataFormat.computeInputFragments(StripedDataFormat.InputContext context)
Compute
DirectInputFragment for the input. |
<T> List<DirectInputFragment> |
HadoopDataSourceCore.findInputFragments(DataDefinition<T> definition,
String basePath,
ResourcePattern resourcePattern) |
<T> List<DirectInputFragment> |
HadoopDataSource.findInputFragments(DataDefinition<T> definition,
String basePath,
ResourcePattern resourcePattern) |
Modifier and Type | Method and Description |
---|---|
<T> ModelInput<T> |
HadoopDataSourceCore.openInput(DataDefinition<T> definition,
DirectInputFragment fragment,
Counter counter) |
<T> ModelInput<T> |
HadoopDataSource.openInput(DataDefinition<T> definition,
DirectInputFragment fragment,
Counter counter) |
Modifier and Type | Method and Description |
---|---|
<T> List<DirectInputFragment> |
KeepAliveDataSource.findInputFragments(DataDefinition<T> definition,
String basePath,
ResourcePattern resourcePattern) |
Modifier and Type | Method and Description |
---|---|
<T> ModelInput<T> |
KeepAliveDataSource.openInput(DataDefinition<T> definition,
DirectInputFragment fragment,
Counter counter) |
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.