org.gridgain.grid.ggfs.mapreduce

Class GridGgfsInputStreamJobAdapter

java.lang.Object

org.gridgain.grid.ggfs.mapreduce.GridGgfsJobAdapter

org.gridgain.grid.ggfs.mapreduce.GridGgfsInputStreamJobAdapter

All Implemented Interfaces:

GridGgfsJob

public abstract class GridGgfsInputStreamJobAdapter
extends GridGgfsJobAdapter

Convenient GridGgfsJob adapter. It limits data returned from GridGgfsInputStream to bytes within the GridGgfsFileRange assigned to the job.

Under the covers it simply puts job's GridGgfsInputStream position to range start and wraps in into GridFixedSizeInputStream limited to range length.

Constructor Summary

Constructors

Constructor and Description
GridGgfsInputStreamJobAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
Object	execute(GridGgfs ggfs, GridGgfsFileRange range, GridGgfsInputStream in) Executes this job.
abstract Object	execute(GridGgfs ggfs, GridGgfsRangeInputStream in) Executes this job.

Methods inherited from class org.gridgain.grid.ggfs.mapreduce.GridGgfsJobAdapter

cancel

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GridGgfsInputStreamJobAdapter

public GridGgfsInputStreamJobAdapter()

Method Detail

execute

public final Object execute(GridGgfs ggfs,
             GridGgfsFileRange range,
             GridGgfsInputStream in)
                     throws GridException,
                            IOException

Executes this job.

Parameters:

ggfs - GGFS 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.

Returns:

Execution result.

Throws:

GridException - If execution failed.

IOException - If file system operation resulted in IO exception.

execute

public abstract Object execute(GridGgfs ggfs,
             GridGgfsRangeInputStream in)
                        throws GridException,
                               IOException

Executes this job.

Parameters:

ggfs - GGFS instance.

in - Input stream.

Returns:

Execution result.

Throws:

GridException - If execution failed.

IOException - If IO exception encountered while working with stream.