com.asakusafw.runtime.directio.hadoop

Interface StripedDataFormat<T>

Type Parameters:

T - the type of target data model

All Superinterfaces:

DataFormat<T>

All Known Implementing Classes:

AbstractOrcFileFormat, AbstractParquetFileFormat, OrcFileFormat, ParquetFileFormat

public interface StripedDataFormat<T>
extends DataFormat<T>

Data model format which has striping information in the format. Client should not implement this interface directly.

Since:

0.7.0

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	StripedDataFormat.InputContext An input context for computing DirectInputFragments.

Method Summary

Modifier and Type	Method and Description
List<DirectInputFragment>	computeInputFragments(StripedDataFormat.InputContext context) Compute DirectInputFragment for the input.

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

getSupportedType

Method Detail

computeInputFragments

List<DirectInputFragment> computeInputFragments(StripedDataFormat.InputContext context)
                                         throws IOException,
                                                InterruptedException

Compute DirectInputFragment for the input.

Parameters:

context - the current input context

Returns:

the computed result

Throws:

IOException - if failed to compute fragments by I/O error

InterruptedException - if interrupted while computing fragments