Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
org.apache.ignite.igfs.mapreduce |
Contains APIs for In-Memory MapReduce over IGFS.
|
org.apache.ignite.igfs.mapreduce.records |
Contains record resolvers for In-Memory MapReduce over IGFS.
|
Modifier and Type | Method and Description |
---|---|
<T,R> R |
IgniteFileSystem.execute(Class<? extends IgfsTask<T,R>> taskCls,
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,
IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
<T,R> R |
IgniteFileSystem.execute(IgfsTask<T,R> task,
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,
IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
Modifier and Type | Method and Description |
---|---|
IgfsRecordResolver |
IgfsTaskArgs.recordResolver()
Gets record resolver for the task.
|
Modifier and Type | Class and Description |
---|---|
class |
IgfsByteDelimiterRecordResolver
Record resolver which adjusts records based on provided delimiters.
|
class |
IgfsFixedLengthRecordResolver
Record resolver which adjusts records to fixed length.
|
class |
IgfsNewLineRecordResolver
Record resolver based on new line detection.
|
class |
IgfsStringDelimiterRecordResolver
Record resolver based on delimiters represented as strings.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015