| Package | Description |
|---|---|
| org.gridgain.grid.events |
Contains Event Subscription functionality together with various events emitted by GridGain.
|
| 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.kernal.processors.ggfs |
Contains high performance file system processer.
|
| Modifier and Type | Method and Description |
|---|---|
GridGgfsPath |
GridGgfsEvent.newPath()
New file or directory path for this event (used in
GridEventType.EVT_GGFS_FILE_RENAMED event). |
GridGgfsPath |
GridGgfsEvent.path()
Path of the file or directory, on which event has occurred.
|
| Constructor and Description |
|---|
GridGgfsEvent(GridGgfsPath path,
GridGgfsPath newPath,
GridNode node,
int type)
Constructs an event instance for path modification event
(
GridEventType.EVT_GGFS_FILE_RENAMED,
GridEventType.EVT_GGFS_DIR_RENAMED). |
GridGgfsEvent(GridGgfsPath path,
GridNode node,
int type)
Constructs an event instance.
|
GridGgfsEvent(GridGgfsPath path,
GridNode node,
int type,
long dataSize)
Constructs an event instance for close events:
(
GridEventType.EVT_GGFS_FILE_CLOSED_READ,
GridEventType.EVT_GGFS_FILE_CLOSED_WRITE). |
GridGgfsEvent(GridGgfsPath path,
GridNode node,
int type,
Map<String,String> meta)
Constructs an event instance for file metadata update events
(
GridEventType.EVT_GGFS_META_UPDATED). |
| Modifier and Type | Field and Description |
|---|---|
static GridGgfsPath |
GridGgfsConfiguration.DFLT_WORKING_DIR
Default user's working directory.
|
| Modifier and Type | Method and Description |
|---|---|
GridGgfsPath |
GridGgfsPath.parent()
Returns the parent of a path or
null if at root. |
GridGgfsPath |
GridGgfsPathSummary.path() |
GridGgfsPath |
GridGgfsFile.path()
Gets path to file.
|
GridGgfsPath |
GridGgfsPath.root()
Returns a root for this path.
|
GridGgfsPath |
GridGgfsPath.suffix(String suffix)
Adds a suffix to the final name in the path.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridGgfsPath> |
GridGgfs.listPaths(GridGgfsPath path)
Lists file paths under the specified path.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridGgfsBlockLocation> |
GridGgfs.affinity(GridGgfsPath path,
long start,
long len)
Gets affinity block locations for data blocks of the file, i.e.
|
Collection<GridGgfsBlockLocation> |
GridGgfs.affinity(GridGgfsPath path,
long start,
long len,
long maxLen)
Get affinity block locations for data blocks of the file.
|
GridGgfsOutputStream |
GridGgfs.append(GridGgfsPath path,
boolean create)
Opens an output stream to an existing file for appending data.
|
GridGgfsOutputStream |
GridGgfs.append(GridGgfsPath path,
int bufSize,
boolean create,
Map<String,String> props)
Opens an output stream to an existing file for appending data.
|
int |
GridGgfsPath.compareTo(GridGgfsPath o) |
GridGgfsOutputStream |
GridGgfs.create(GridGgfsPath path,
boolean overwrite)
Creates a file and opens it for writing.
|
GridGgfsOutputStream |
GridGgfs.create(GridGgfsPath path,
int bufSize,
boolean overwrite,
GridUuid affKey,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
boolean |
GridGgfs.delete(GridGgfsPath path,
boolean recursive)
Deletes file.
|
boolean |
GridGgfs.exists(GridGgfsPath path)
Checks if the specified path exists in the file system.
|
GridGgfsFile |
GridGgfs.info(GridGgfsPath path)
Gets file information for the specified path.
|
boolean |
GridGgfsPath.isSame(GridGgfsPath path)
Checks if paths are identical.
|
boolean |
GridGgfsPath.isSubDirectoryOf(GridGgfsPath path)
Checks whether this path is a sub-directory of argument.
|
Collection<GridGgfsFile> |
GridGgfs.listFiles(GridGgfsPath path)
Lists files under the specified path.
|
Collection<GridGgfsPath> |
GridGgfs.listPaths(GridGgfsPath path)
Lists file paths under the specified path.
|
void |
GridGgfs.mkdirs(GridGgfsPath path)
Creates directories under specified path.
|
void |
GridGgfs.mkdirs(GridGgfsPath path,
Map<String,String> props)
Creates directories under specified path with the specified properties.
|
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.
|
void |
GridGgfsPathSummary.path(GridGgfsPath path) |
void |
GridGgfs.rename(GridGgfsPath src,
GridGgfsPath dest)
Renames/moves a file.
|
void |
GridGgfs.setTimes(GridGgfsPath path,
long accessTime,
long modificationTime)
Sets last access time and last modification time for a given path.
|
long |
GridGgfs.size(GridGgfsPath path)
Determines size of the file denoted by provided path.
|
GridGgfsPathSummary |
GridGgfs.summary(GridGgfsPath path)
Gets summary (total number of files, total number of directories and total length)
for a given path.
|
GridGgfsFile |
GridGgfs.update(GridGgfsPath path,
Map<String,String> props)
Updates file information for the specified path.
|
| Modifier and Type | Method and Description |
|---|---|
<T,R> GridFuture<R> |
GridGgfs.execute(Class<? extends GridGgfsTask<T,R>> taskCls,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes GGFS task asynchronously with overridden maximum range length (see
GridGgfsConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> GridFuture<R> |
GridGgfs.execute(Class<? extends GridGgfsTask<T,R>> taskCls,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
T arg)
Executes GGFS task asynchronously.
|
<T,R> GridFuture<R> |
GridGgfs.execute(GridGgfsTask<T,R> task,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes GGFS task asynchronously with overridden maximum range length (see
GridGgfsConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> GridFuture<R> |
GridGgfs.execute(GridGgfsTask<T,R> task,
GridGgfsRecordResolver rslvr,
Collection<GridGgfsPath> paths,
T arg)
Executes GGFS task asynchronously.
|
| Constructor and Description |
|---|
GridGgfsPath(GridGgfsPath parentPath,
String childPath)
Resolve a child path against a parent path.
|
GridGgfsPathSummary(GridGgfsPath path)
Construct empty path summary.
|
| Modifier and Type | Method and Description |
|---|---|
GridGgfsPath |
GridGgfsFileRange.path()
Gets file path.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridGgfsPath> |
GridGgfsTaskArgs.paths()
Gets file paths to process.
|
| 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.
|
| Constructor and Description |
|---|
GridGgfsFileRange(GridGgfsPath path,
long start,
long len)
Creates file range.
|
| Modifier and Type | Method and Description |
|---|---|
GridComputeJob |
GridNoopGgfsProcessor.createJob(GridGgfsJob job,
String ggfsName,
GridGgfsPath path,
long start,
long length,
GridGgfsRecordResolver recRslv)
Create compute job for the given GGFS job.
|
abstract GridComputeJob |
GridGgfsProcessorAdapter.createJob(GridGgfsJob job,
String ggfsName,
GridGgfsPath path,
long start,
long length,
GridGgfsRecordResolver recRslv)
Create compute job for the given GGFS job.
|
Copyright © 2014. All rights reserved.