| Package | Description |
|---|---|
| org.gridgain.grid.ggfs |
Contains GridGain File System APIs.
|
| 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 |
|---|---|
GridGgfsInputStream |
GridGgfs.open(GridGgfsPath path)
Opens a file for reading.
|
GridGgfsInputStream |
GridGgfs.open(GridGgfsPath path,
int bufSize)
Opens a file for reading.
|
GridGgfsInputStream |
GridGgfs.open(GridGgfsPath path,
int bufSize,
int seqReadsBeforePrefetch)
Opens a file for reading.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridGgfsRangeInputStream
Decorator for regular
GridGgfsInputStream which streams only data within the given range. |
| Modifier and Type | Method and Description |
|---|---|
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.
|
GridGgfsRangeInputStream(GridGgfsInputStream is,
long start,
long maxLen)
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.
|
Copyright © 2014. All rights reserved.