| Package | Description |
|---|---|
| org.gridgain.grid.ggfs |
Contains GridGain File System APIs.
|
| org.gridgain.grid.ggfs.mapreduce |
Contains APIs for In-Memory MapReduce over GGFS.
|
| Modifier and Type | Method and Description |
|---|---|
<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.
|
| 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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridGgfsTaskNoReduceAdapter<T,R>
Convenient
GridGgfsTask adapter with empty reduce step. |
Copyright © 2014. All rights reserved.