public abstract class IgfsInputStreamJobAdapter extends IgfsJobAdapter
IgfsJob
adapter. It limits data returned from IgfsInputStream
to bytes within
the IgfsFileRange
assigned to the job.
Under the covers it simply puts job's IgfsInputStream
position to range start and wraps in into
GridFixedSizeInputStream
limited to range length.
Constructor and Description |
---|
IgfsInputStreamJobAdapter() |
Modifier and Type | Method and Description |
---|---|
Object |
execute(IgniteFs igfs,
IgfsFileRange range,
IgfsInputStream in)
Executes this job.
|
abstract Object |
execute(IgniteFs igfs,
IgfsRangeInputStream in)
Executes this job.
|
cancel
public final Object execute(IgniteFs igfs, IgfsFileRange range, IgfsInputStream in) throws IgniteException, IOException
igfs
- IGFS instance.range
- File range aligned to record boundaries.in
- Input stream for split file. This input stream is not aligned to range and points to file start
by default.IgniteException
- If execution failed.IOException
- If file system operation resulted in IO exception.public abstract Object execute(IgniteFs igfs, IgfsRangeInputStream in) throws IgniteException, IOException
igfs
- IGFS instance.in
- Input stream.IgniteException
- If execution failed.IOException
- If IO exception encountered while working with stream.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015