Uses of Interface
org.gridgain.grid.ggfs.mapreduce.GridGgfsRecordResolver

Packages that use GridGgfsRecordResolver

Package	Description
org.gridgain.grid.ggfs	Contains GridGain File System APIs.
org.gridgain.grid.ggfs.mapreduce	Contains APIs for In-Memory MapReduce over GGFS.
org.gridgain.grid.ggfs.mapreduce.records	Contains record resolvers for In-Memory MapReduce over GGFS.
org.gridgain.grid.kernal.processors.ggfs	Contains high performance file system processer.

Uses of GridGgfsRecordResolver in org.gridgain.grid.ggfs

Methods in org.gridgain.grid.ggfs with parameters of type GridGgfsRecordResolver

Modifier and Type	Method and Description
<T,R> GridFuture<R>	GridGgfs.execute(Class<? extends GridGgfsTask<T,R>> taskCls, GridGgfsRecordResolver rslvr, Collection<GridGgfsPath> paths, boolean skipNonExistentFiles, long maxRangeLen, T arg) Executes GGFS task asynchronously with overridden maximum range length (see GridGgfsConfiguration.getMaximumTaskRangeLength() for more information).
<T,R> GridFuture<R>	GridGgfs.execute(Class<? extends GridGgfsTask<T,R>> taskCls, GridGgfsRecordResolver rslvr, Collection<GridGgfsPath> paths, T arg) Executes GGFS task asynchronously.
<T,R> GridFuture<R>	GridGgfs.execute(GridGgfsTask<T,R> task, GridGgfsRecordResolver rslvr, Collection<GridGgfsPath> paths, boolean skipNonExistentFiles, long maxRangeLen, T arg) Executes GGFS task asynchronously with overridden maximum range length (see GridGgfsConfiguration.getMaximumTaskRangeLength() for more information).
<T,R> GridFuture<R>	GridGgfs.execute(GridGgfsTask<T,R> task, GridGgfsRecordResolver rslvr, Collection<GridGgfsPath> paths, T arg) Executes GGFS task asynchronously.

Uses of GridGgfsRecordResolver in org.gridgain.grid.ggfs.mapreduce

Methods in org.gridgain.grid.ggfs.mapreduce that return GridGgfsRecordResolver

Modifier and Type	Method and Description
GridGgfsRecordResolver	GridGgfsTaskArgs.recordResolver() Gets record resolver for the task.

Uses of GridGgfsRecordResolver in org.gridgain.grid.ggfs.mapreduce.records

Classes in org.gridgain.grid.ggfs.mapreduce.records that implement GridGgfsRecordResolver

Modifier and Type	Class and Description
class	GridGgfsByteDelimiterRecordResolver Record resolver which adjusts records based on provided delimiters.
class	GridGgfsFixedLengthRecordResolver Record resolver which adjusts records to fixed length.
class	GridGgfsNewLineRecordResolver Record resolver based on new line detection.
class	GridGgfsStringDelimiterRecordResolver Record resolver based on delimiters represented as strings.

Uses of GridGgfsRecordResolver in org.gridgain.grid.kernal.processors.ggfs

Methods in org.gridgain.grid.kernal.processors.ggfs with parameters of type GridGgfsRecordResolver

Modifier and Type	Method and Description
GridComputeJob	GridNoopGgfsProcessor.createJob(GridGgfsJob job, String ggfsName, GridGgfsPath path, long start, long length, GridGgfsRecordResolver recRslv) Create compute job for the given GGFS job.
abstract GridComputeJob	GridGgfsProcessorAdapter.createJob(GridGgfsJob job, String ggfsName, GridGgfsPath path, long start, long length, GridGgfsRecordResolver recRslv) Create compute job for the given GGFS job.