| Package | Description |
|---|---|
| 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 |
|---|---|
IgfsFileRange |
IgfsRecordResolver.resolveRecords(IgniteFileSystem fs,
IgfsInputStream stream,
IgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
| Modifier and Type | Method and Description |
|---|---|
abstract IgfsJob |
IgfsTask.createJob(IgfsPath path,
IgfsFileRange range,
IgfsTaskArgs<T> args)
Callback invoked during task map procedure to create job that will process specified split
for IGFS file.
|
Object |
IgfsJob.execute(IgniteFileSystem igfs,
IgfsFileRange range,
IgfsInputStream in)
Executes this job.
|
Object |
IgfsInputStreamJobAdapter.execute(IgniteFileSystem igfs,
IgfsFileRange range,
IgfsInputStream in)
Executes this job.
|
IgfsFileRange |
IgfsRecordResolver.resolveRecords(IgniteFileSystem fs,
IgfsInputStream stream,
IgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
| Constructor and Description |
|---|
IgfsRangeInputStream(IgfsInputStream is,
IgfsFileRange range)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsFileRange |
IgfsFixedLengthRecordResolver.resolveRecords(IgniteFileSystem fs,
IgfsInputStream stream,
IgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
IgfsFileRange |
IgfsByteDelimiterRecordResolver.resolveRecords(IgniteFileSystem fs,
IgfsInputStream stream,
IgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsFileRange |
IgfsFixedLengthRecordResolver.resolveRecords(IgniteFileSystem fs,
IgfsInputStream stream,
IgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
IgfsFileRange |
IgfsByteDelimiterRecordResolver.resolveRecords(IgniteFileSystem fs,
IgfsInputStream stream,
IgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016