com.asakusafw.runtime.directio

Class BinaryStreamFormat<T>

java.lang.Object

com.asakusafw.runtime.directio.BinaryStreamFormat<T>

Type Parameters:

T - the type of target data model

All Implemented Interfaces:

DataFormat<T>, FragmentableDataFormat<T>

Direct Known Subclasses:

ConfigurableBinaryStreamFormat

public abstract class BinaryStreamFormat<T>
extends Object
implements FragmentableDataFormat<T>

Data model format of InputStream / OutputStream . This implementation class must have a public constructor without any parameters.

Since:

0.2.5

Version:

0.9.1

Constructor Summary

Constructors

Constructor and Description
BinaryStreamFormat()

Method Summary

Modifier and Type	Method and Description
ModelInput<T>	createInput(Class<? extends T> dataType, String path, InputStream stream) Creates a new ModelInput for the specified properties.
abstract ModelInput<T>	createInput(Class<? extends T> dataType, String path, InputStream stream, long offset, long fragmentSize) Creates a new ModelInput for the specified properties.
abstract ModelOutput<T>	createOutput(Class<? extends T> dataType, String path, OutputStream stream) Creates a new ModelOutput for the specified properties.

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

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

getSupportedType

Constructor Detail

BinaryStreamFormat

public BinaryStreamFormat()

Method Detail

createInput

public ModelInput<T> createInput(Class<? extends T> dataType,
                                 String path,
                                 InputStream stream)
                          throws IOException,
                                 InterruptedException

Creates a new ModelInput for the specified properties.

Parameters:

dataType - the target data type

path - the path about the target stream (for label)

stream - the target stream

Returns:

the created reader

Throws:

IOException - if failed to create reader

InterruptedException - if interrupted

IllegalArgumentException - if this does not support target property sequence, or any parameter is null

Since:

0.9.1

createInput

public abstract ModelInput<T> createInput(Class<? extends T> dataType,
                                          String path,
                                          InputStream stream,
                                          long offset,
                                          long fragmentSize)
                                   throws IOException,
                                          InterruptedException

Creates a new ModelInput for the specified properties.

Parameters:

dataType - the target data type

path - the path about the target stream (for label)

stream - the target stream

offset - starting stream offset

fragmentSize - suggested fragment bytes count, or -1 as infinite

Returns:

the created reader

Throws:

IOException - if failed to create reader

InterruptedException - if interrupted

IllegalArgumentException - if this does not support target property sequence, or any parameter is null

createOutput

public abstract ModelOutput<T> createOutput(Class<? extends T> dataType,
                                            String path,
                                            OutputStream stream)
                                     throws IOException,
                                            InterruptedException

Creates a new ModelOutput for the specified properties.

Parameters:

dataType - the target data type

path - the path about the target stream (for label)

stream - the target stream

Returns:

the created writer

Throws:

IOException - if failed to create writer

InterruptedException - if interrupted

IllegalArgumentException - if this does not support property sequence, or any parameter is null