com.asakusafw.runtime.io.util

Interface InputSplitter

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface InputSplitter

Splits InputStream.

Since:

0.10.3

Method Summary

Modifier and Type	Method and Description
default long	getLowerLimitSize() Returns the lower limit of split size.
default long	getPreferredSize() Returns the preferred split size.
InputStream	trim(InputStream input, long offset, long splitSize) Trims InputStream to provide the correct split data.

Method Detail

trim

InputStream trim(InputStream input,
                 long offset,
                 long splitSize)
          throws IOException

Trims InputStream to provide the correct split data.

Parameters:

input - the input, which skipped leading data until the offset position

offset - the current input offset in bytes

splitSize - the preferred split size in bytes (may be larger than the input)

Returns:

the trimmed InputStream

Throws:

IOException - if I/O error was occurred while trimming the input

getPreferredSize

default long getPreferredSize()

Returns the preferred split size.

Returns:

the preferred split size in bytes

getLowerLimitSize

default long getLowerLimitSize()

Returns the lower limit of split size. The each fragment must have size greater than or equal to the returned value.

Returns:

the lower limit of split size in bytes