| Package | Description |
|---|---|
| org.gridgain.grid.ggfs.mapreduce |
Contains APIs for In-Memory MapReduce over GGFS.
|
| org.gridgain.grid.kernal.processors.ggfs |
Contains high performance file system processer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridGgfsInputStreamJobAdapter
Convenient
GridGgfsJob adapter. |
class |
GridGgfsJobAdapter
Adapter for
GridGgfsJob with no-op implementation of GridGgfsJobAdapter.cancel() method. |
| Modifier and Type | Method and Description |
|---|---|
abstract GridGgfsJob |
GridGgfsTask.createJob(GridGgfsPath path,
GridGgfsFileRange range,
GridGgfsTaskArgs<T> args)
Callback invoked during task map procedure to create job that will process specified split
for GGFS file.
|
| 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.
|
Copyright © 2014. All rights reserved.