| Package | Description |
|---|---|
| org.gridgain.grid.ggfs.mapreduce |
Contains APIs for In-Memory MapReduce over GGFS.
|
| org.gridgain.grid.ggfs.mapreduce.records |
Contains record resolvers for In-Memory MapReduce over GGFS.
|
| Modifier and Type | Method and Description |
|---|---|
GridGgfsFileRange |
GridGgfsRecordResolver.resolveRecords(GridGgfs ggfs,
GridGgfsInputStream stream,
GridGgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
| 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.
|
Object |
GridGgfsJob.execute(GridGgfs ggfs,
GridGgfsFileRange range,
GridGgfsInputStream in)
Executes this job.
|
Object |
GridGgfsInputStreamJobAdapter.execute(GridGgfs ggfs,
GridGgfsFileRange range,
GridGgfsInputStream in)
Executes this job.
|
GridGgfsFileRange |
GridGgfsRecordResolver.resolveRecords(GridGgfs ggfs,
GridGgfsInputStream stream,
GridGgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
| Constructor and Description |
|---|
GridGgfsRangeInputStream(GridGgfsInputStream is,
GridGgfsFileRange range)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
GridGgfsFileRange |
GridGgfsFixedLengthRecordResolver.resolveRecords(GridGgfs ggfs,
GridGgfsInputStream stream,
GridGgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
GridGgfsFileRange |
GridGgfsByteDelimiterRecordResolver.resolveRecords(GridGgfs ggfs,
GridGgfsInputStream stream,
GridGgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
| Modifier and Type | Method and Description |
|---|---|
GridGgfsFileRange |
GridGgfsFixedLengthRecordResolver.resolveRecords(GridGgfs ggfs,
GridGgfsInputStream stream,
GridGgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
GridGgfsFileRange |
GridGgfsByteDelimiterRecordResolver.resolveRecords(GridGgfs ggfs,
GridGgfsInputStream stream,
GridGgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
Copyright © 2014. All rights reserved.