Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
org.apache.ignite.igfs.mapreduce |
Contains APIs for In-Memory MapReduce over IGFS.
|
Modifier and Type | Method and Description |
---|---|
<T,R> R |
IgniteFileSystem.execute(IgfsTask<T,R> task,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes IGFS task with overridden maximum range length (see
FileSystemConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> R |
IgniteFileSystem.execute(IgfsTask<T,R> task,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
<T,R> IgniteFuture<R> |
IgniteFileSystem.executeAsync(IgfsTask<T,R> task,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes IGFS task asynchronously with overridden maximum range length (see
FileSystemConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> IgniteFuture<R> |
IgniteFileSystem.executeAsync(IgfsTask<T,R> task,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task asynchronously.
|
Modifier and Type | Method and Description |
---|---|
<T,R> R |
IgniteFileSystem.execute(Class<? extends IgfsTask<T,R>> taskCls,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes IGFS task with overridden maximum range length (see
FileSystemConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> R |
IgniteFileSystem.execute(Class<? extends IgfsTask<T,R>> taskCls,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
<T,R> IgniteFuture<R> |
IgniteFileSystem.executeAsync(Class<? extends IgfsTask<T,R>> taskCls,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes IGFS task asynchronously with overridden maximum range length (see
FileSystemConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> IgniteFuture<R> |
IgniteFileSystem.executeAsync(Class<? extends IgfsTask<T,R>> taskCls,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task asynchronously.
|
Modifier and Type | Class and Description |
---|---|
class |
IgfsTaskNoReduceAdapter<T,R>
Convenient
IgfsTask adapter with empty reduce step. |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.2 Release Date : February 6 2019