| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.cache.eviction.igfs |
Contains IGFS LRU eviction policy implementations.
|
| org.apache.ignite.events |
Contains Event Subscription functionality together with various events emitted by Ignite.
|
| org.apache.ignite.igfs |
Contains IGnite File System APIs.
|
| org.apache.ignite.igfs.mapreduce |
Contains APIs for In-Memory MapReduce over IGFS.
|
| org.apache.ignite.igfs.secondary |
Contains APIs for IGFS secondary file system.
|
| org.apache.ignite.internal.igfs.common |
Contains IGFS classes that are common between client and server.
|
| org.apache.ignite.internal.processors.igfs |
Contains high performance file system processer.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsPath> |
IgniteFileSystem.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsBlockLocation> |
IgniteFileSystem.affinity(IgfsPath path,
long start,
long len)
Gets affinity block locations for data blocks of the file, i.e. the nodes, on which the blocks
are stored.
|
Collection<IgfsBlockLocation> |
IgniteFileSystem.affinity(IgfsPath path,
long start,
long len,
long maxLen)
Get affinity block locations for data blocks of the file.
|
IgfsOutputStream |
IgniteFileSystem.append(IgfsPath path,
boolean create)
Opens an output stream to an existing file for appending data.
|
IgfsOutputStream |
IgniteFileSystem.append(IgfsPath path,
int bufSize,
boolean create,
Map<String,String> props)
Opens an output stream to an existing file for appending data.
|
IgfsOutputStream |
IgniteFileSystem.create(IgfsPath path,
boolean overwrite)
Creates a file and opens it for writing.
|
IgfsOutputStream |
IgniteFileSystem.create(IgfsPath path,
int bufSize,
boolean overwrite,
IgniteUuid affKey,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
IgfsOutputStream |
IgniteFileSystem.create(IgfsPath path,
int bufSize,
boolean overwrite,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
boolean |
IgniteFileSystem.delete(IgfsPath path,
boolean recursive)
Deletes file.
|
boolean |
IgniteFileSystem.exists(IgfsPath path)
Checks if the specified path exists in the file system.
|
IgfsFile |
IgniteFileSystem.info(IgfsPath path)
Gets file information for the specified path.
|
Collection<IgfsFile> |
IgniteFileSystem.listFiles(IgfsPath path)
Lists files under the specified path.
|
Collection<IgfsPath> |
IgniteFileSystem.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
void |
IgniteFileSystem.mkdirs(IgfsPath path)
Creates directories under specified path.
|
void |
IgniteFileSystem.mkdirs(IgfsPath path,
Map<String,String> props)
Creates directories under specified path with the specified properties.
|
IgfsInputStream |
IgniteFileSystem.open(IgfsPath path)
Opens a file for reading.
|
IgfsInputStream |
IgniteFileSystem.open(IgfsPath path,
int bufSize)
Opens a file for reading.
|
IgfsInputStream |
IgniteFileSystem.open(IgfsPath path,
int bufSize,
int seqReadsBeforePrefetch)
Opens a file for reading.
|
void |
IgniteFileSystem.rename(IgfsPath src,
IgfsPath dest)
Renames/moves a file.
|
void |
IgniteFileSystem.setTimes(IgfsPath path,
long accessTime,
long modificationTime)
Sets last access time and last modification time for a given path.
|
long |
IgniteFileSystem.size(IgfsPath path)
Determines size of the file denoted by provided path.
|
IgfsPathSummary |
IgniteFileSystem.summary(IgfsPath path)
Gets summary (total number of files, total number of directories and total length)
for a given path.
|
IgfsFile |
IgniteFileSystem.update(IgfsPath path,
Map<String,String> props)
Updates file information for the specified path.
|
| 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 |
|---|---|
boolean |
IgfsPerBlockLruEvictionPolicy.exclude(IgfsPath path)
Check whether provided path must be excluded from evictions.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsPath |
IgfsEvent.newPath()
New file or directory path for this event (used in
EventType.EVT_IGFS_FILE_RENAMED event). |
IgfsPath |
IgfsEvent.path()
Path of the file or directory, on which event has occurred.
|
| Constructor and Description |
|---|
IgfsEvent(IgfsPath path,
ClusterNode node,
int type)
Constructs an event instance.
|
IgfsEvent(IgfsPath path,
ClusterNode node,
int type,
long dataSize)
Constructs an event instance for close events:
(
EventType.EVT_IGFS_FILE_CLOSED_READ,
EventType.EVT_IGFS_FILE_CLOSED_WRITE). |
IgfsEvent(IgfsPath path,
ClusterNode node,
int type,
Map<String,String> meta)
Constructs an event instance for file metadata update events
(
EventType.EVT_IGFS_META_UPDATED). |
IgfsEvent(IgfsPath path,
IgfsPath newPath,
ClusterNode node,
int type)
Constructs an event instance for path modification event
(
EventType.EVT_IGFS_FILE_RENAMED,
EventType.EVT_IGFS_DIR_RENAMED). |
| Modifier and Type | Method and Description |
|---|---|
IgfsPath |
IgfsPath.parent()
Returns the parent of a path or
null if at root. |
IgfsPath |
IgfsPathSummary.path() |
IgfsPath |
IgfsFile.path()
Gets path to file.
|
IgfsPath |
IgfsPath.root()
Returns a root for this path.
|
IgfsPath |
IgfsPath.suffix(String suffix)
Adds a suffix to the final name in the path.
|
| Modifier and Type | Method and Description |
|---|---|
int |
IgfsPath.compareTo(IgfsPath o) |
boolean |
IgfsPath.isSame(IgfsPath path)
Checks if paths are identical.
|
boolean |
IgfsPath.isSubDirectoryOf(IgfsPath path)
Checks whether this path is a sub-directory of argument.
|
void |
IgfsPathSummary.path(IgfsPath path) |
| Constructor and Description |
|---|
IgfsPath(IgfsPath parentPath,
String childPath)
Resolve a child path against a parent path.
|
IgfsPathSummary(IgfsPath path)
Construct empty path summary.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsPath |
IgfsFileRange.path()
Gets file path.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsPath> |
IgfsTaskArgs.paths()
Gets file paths to process.
|
| 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.
|
| Constructor and Description |
|---|
IgfsFileRange(IgfsPath path,
long start,
long len)
Creates file range.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsPath> |
IgfsSecondaryFileSystem.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
| Modifier and Type | Method and Description |
|---|---|
OutputStream |
IgfsSecondaryFileSystem.append(IgfsPath path,
int bufSize,
boolean create,
Map<String,String> props)
Opens an output stream to an existing file for appending data.
|
OutputStream |
IgfsSecondaryFileSystem.create(IgfsPath path,
boolean overwrite)
Creates a file and opens it for writing.
|
OutputStream |
IgfsSecondaryFileSystem.create(IgfsPath path,
int bufSize,
boolean overwrite,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
boolean |
IgfsSecondaryFileSystem.delete(IgfsPath path,
boolean recursive)
Deletes file.
|
boolean |
IgfsSecondaryFileSystem.exists(IgfsPath path)
Checks if the specified path exists.
|
IgfsFile |
IgfsSecondaryFileSystem.info(IgfsPath path)
Gets file information for the specified path.
|
Collection<IgfsFile> |
IgfsSecondaryFileSystem.listFiles(IgfsPath path)
Lists files under the specified path.
|
Collection<IgfsPath> |
IgfsSecondaryFileSystem.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
void |
IgfsSecondaryFileSystem.mkdirs(IgfsPath path)
Creates directories under specified path.
|
void |
IgfsSecondaryFileSystem.mkdirs(IgfsPath path,
Map<String,String> props)
Creates directories under specified path with the specified properties.
|
IgfsSecondaryFileSystemPositionedReadable |
IgfsSecondaryFileSystem.open(IgfsPath path,
int bufSize)
Opens a file for reading.
|
void |
IgfsSecondaryFileSystem.rename(IgfsPath src,
IgfsPath dest)
Renames/moves a file.
|
IgfsFile |
IgfsSecondaryFileSystem.update(IgfsPath path,
Map<String,String> props)
Updates file information for the specified path.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsPath |
IgfsPathControlRequest.destinationPath() |
IgfsPath |
IgfsPathControlRequest.path() |
| Modifier and Type | Method and Description |
|---|---|
void |
IgfsPathControlRequest.destinationPath(IgfsPath destPath) |
void |
IgfsLogger.logAppend(long streamId,
IgfsPath path,
IgfsMode mode,
int bufSize)
Log file append event.
|
void |
IgfsLogger.logCreate(long streamId,
IgfsPath path,
IgfsMode mode,
boolean overwrite,
int bufSize,
int replication,
long blockSize)
Log file create event.
|
void |
IgfsLogger.logDelete(IgfsPath path,
IgfsMode mode,
boolean recursive)
Log delete event.
|
void |
IgfsLogger.logListDirectory(IgfsPath path,
IgfsMode mode,
String[] files)
Log directory listing event.
|
void |
IgfsLogger.logMakeDirectory(IgfsPath path,
IgfsMode mode)
Log directory creation event.
|
void |
IgfsLogger.logOpen(long streamId,
IgfsPath path,
IgfsMode mode,
int bufSize,
long dataLen)
Log file open event.
|
void |
IgfsLogger.logRename(IgfsPath path,
IgfsMode mode,
IgfsPath destPath)
Log rename event.
|
void |
IgfsPathControlRequest.path(IgfsPath path) |
void |
IgfsControlResponse.response(IgfsPath res) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgfsControlResponse.paths(Collection<IgfsPath> res) |
| Modifier and Type | Field and Description |
|---|---|
protected IgfsPath |
IgfsInputStreamImpl.path
Path to file.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsPath |
IgfsFileImpl.path()
Gets path to file.
|
IgfsPath |
IgfsFileInfo.path() |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsPath> |
IgfsImpl.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
Collection<IgfsPath> |
IgfsAsyncImpl.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
List<T2<IgfsPath,IgfsMode>> |
IgfsModeResolver.modesOrdered() |
List<T2<IgfsPath,IgfsMode>> |
IgfsPaths.pathModes() |
Collection<IgfsPath> |
IgfsTaskArgsImpl.paths()
Gets file paths to process.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsBlockLocation> |
IgfsImpl.affinity(IgfsPath path,
long start,
long len)
Gets affinity block locations for data blocks of the file, i.e. the nodes, on which the blocks
are stored.
|
Collection<IgfsBlockLocation> |
IgfsAsyncImpl.affinity(IgfsPath path,
long start,
long len)
Gets affinity block locations for data blocks of the file, i.e. the nodes, on which the blocks
are stored.
|
Collection<IgfsBlockLocation> |
IgfsImpl.affinity(IgfsPath path,
long start,
long len,
long maxLen)
Get affinity block locations for data blocks of the file.
|
Collection<IgfsBlockLocation> |
IgfsAsyncImpl.affinity(IgfsPath path,
long start,
long len,
long maxLen)
Get affinity block locations for data blocks of the file.
|
IgfsOutputStream |
IgfsImpl.append(IgfsPath path,
boolean create)
Opens an output stream to an existing file for appending data.
|
IgfsOutputStream |
IgfsAsyncImpl.append(IgfsPath path,
boolean create)
Opens an output stream to an existing file for appending data.
|
IgfsOutputStream |
IgfsImpl.append(IgfsPath path,
int bufSize,
boolean create,
Map<String,String> props)
Opens an output stream to an existing file for appending data.
|
IgfsOutputStream |
IgfsAsyncImpl.append(IgfsPath path,
int bufSize,
boolean create,
Map<String,String> props)
Opens an output stream to an existing file for appending data.
|
IgfsSecondaryOutputStreamDescriptor |
IgfsMetaManager.appendDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
int bufSize)
Append to a file in DUAL mode.
|
IgfsOutputStream |
IgfsImpl.create(IgfsPath path,
boolean overwrite)
Creates a file and opens it for writing.
|
IgfsOutputStream |
IgfsAsyncImpl.create(IgfsPath path,
boolean overwrite)
Creates a file and opens it for writing.
|
IgfsOutputStream |
IgfsImpl.create(IgfsPath path,
int bufSize,
boolean overwrite,
IgniteUuid affKey,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
IgfsOutputStream |
IgfsAsyncImpl.create(IgfsPath path,
int bufSize,
boolean overwrite,
IgniteUuid affKey,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
IgfsOutputStream |
IgfsImpl.create(IgfsPath path,
int bufSize,
boolean overwrite,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
IgfsOutputStream |
IgfsAsyncImpl.create(IgfsPath path,
int bufSize,
boolean overwrite,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
IgfsSecondaryOutputStreamDescriptor |
IgfsMetaManager.createDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
boolean simpleCreate,
Map<String,String> props,
boolean overwrite,
int bufSize,
short replication,
long blockSize,
IgniteUuid affKey)
Create the file in DUAL mode.
|
ComputeJob |
IgfsNoopProcessor.createJob(IgfsJob job,
String igfsName,
IgfsPath path,
long start,
long length,
IgfsRecordResolver recRslv)
Create compute job for the given IGFS job.
|
ComputeJob |
IgfsProcessor.createJob(IgfsJob job,
String igfsName,
IgfsPath path,
long start,
long len,
IgfsRecordResolver recRslv)
Create compute job for the given IGFS job.
|
abstract ComputeJob |
IgfsProcessorAdapter.createJob(IgfsJob job,
String igfsName,
IgfsPath path,
long start,
long length,
IgfsRecordResolver recRslv)
Create compute job for the given IGFS job.
|
IgniteInternalFuture<byte[]> |
IgfsDataManager.dataBlock(IgfsFileInfo fileInfo,
IgfsPath path,
long blockIdx,
IgfsSecondaryFileSystemPositionedReadable secReader)
Get data block for specified file ID and block index.
|
boolean |
IgfsImpl.delete(IgfsPath path,
boolean recursive)
Deletes file.
|
boolean |
IgfsAsyncImpl.delete(IgfsPath path,
boolean recursive)
Deletes file.
|
boolean |
IgfsMetaManager.deleteDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
boolean recursive)
Delete path in DUAL mode.
|
boolean |
IgfsEx.evictExclude(IgfsPath path,
boolean primary)
Whether this path is excluded from evictions.
|
boolean |
IgfsImpl.evictExclude(IgfsPath path,
boolean primary)
Whether this path is excluded from evictions.
|
boolean |
IgfsAsyncImpl.evictExclude(IgfsPath path,
boolean primary)
Whether this path is excluded from evictions.
|
boolean |
IgfsImpl.exists(IgfsPath path)
Checks if the specified path exists in the file system.
|
boolean |
IgfsAsyncImpl.exists(IgfsPath path)
Checks if the specified path exists in the file system.
|
IgniteUuid |
IgfsMetaManager.fileId(IgfsPath path)
Gets file ID for specified path.
|
List<IgniteUuid> |
IgfsMetaManager.fileIds(IgfsPath path)
Gets all file IDs for components of specified path.
|
IgfsFile |
IgfsImpl.info(IgfsPath path)
Gets file information for the specified path.
|
IgfsFile |
IgfsAsyncImpl.info(IgfsPath path)
Gets file information for the specified path.
|
Collection<IgfsFile> |
IgfsImpl.listFiles(IgfsPath path)
Lists files under the specified path.
|
Collection<IgfsFile> |
IgfsAsyncImpl.listFiles(IgfsPath path)
Lists files under the specified path.
|
Collection<IgfsPath> |
IgfsImpl.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
Collection<IgfsPath> |
IgfsAsyncImpl.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
void |
IgfsImpl.mkdirs(IgfsPath path)
Creates directories under specified path.
|
void |
IgfsAsyncImpl.mkdirs(IgfsPath path)
Creates directories under specified path.
|
void |
IgfsImpl.mkdirs(IgfsPath path,
Map<String,String> props)
Creates directories under specified path with the specified properties.
|
void |
IgfsAsyncImpl.mkdirs(IgfsPath path,
Map<String,String> props)
Creates directories under specified path with the specified properties.
|
boolean |
IgfsMetaManager.mkdirsDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
Map<String,String> props)
Create directory in DUAL mode.
|
IgfsInputStreamAdapter |
IgfsEx.open(IgfsPath path)
Opens a file for reading.
|
IgfsInputStreamAdapter |
IgfsImpl.open(IgfsPath path)
Opens a file for reading.
|
IgfsInputStreamAdapter |
IgfsAsyncImpl.open(IgfsPath path)
Opens a file for reading.
|
IgfsInputStreamAdapter |
IgfsEx.open(IgfsPath path,
int bufSize)
Opens a file for reading.
|
IgfsInputStreamAdapter |
IgfsImpl.open(IgfsPath path,
int bufSize)
Opens a file for reading.
|
IgfsInputStreamAdapter |
IgfsAsyncImpl.open(IgfsPath path,
int bufSize)
Opens a file for reading.
|
IgfsInputStreamAdapter |
IgfsEx.open(IgfsPath path,
int bufSize,
int seqReadsBeforePrefetch)
Opens a file for reading.
|
IgfsInputStreamAdapter |
IgfsImpl.open(IgfsPath path,
int bufSize,
int seqReadsBeforePrefetch)
Opens a file for reading.
|
IgfsInputStreamAdapter |
IgfsAsyncImpl.open(IgfsPath path,
int bufSize,
int seqReadsBeforePrefetch)
Opens a file for reading.
|
IgfsSecondaryInputStreamDescriptor |
IgfsMetaManager.openDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
int bufSize)
Open file in DUAL mode.
|
IgfsFileInfo.Builder |
IgfsFileInfo.Builder.path(IgfsPath path) |
IgfsFileInfo |
IgfsMetaManager.removeIfEmpty(IgniteUuid parentId,
String fileName,
IgniteUuid fileId,
IgfsPath path,
boolean rmvLocked)
Remove file from the file system structure.
|
void |
IgfsImpl.rename(IgfsPath src,
IgfsPath dest)
Renames/moves a file.
|
void |
IgfsAsyncImpl.rename(IgfsPath src,
IgfsPath dest)
Renames/moves a file.
|
boolean |
IgfsMetaManager.renameDual(IgfsSecondaryFileSystem fs,
IgfsPath src,
IgfsPath dest)
Rename path in DUAL mode.
|
Set<IgfsMode> |
IgfsModeResolver.resolveChildrenModes(IgfsPath path) |
IgfsMode |
IgfsModeResolver.resolveMode(IgfsPath path)
Resolves IGFS mode for the given path.
|
void |
IgfsImpl.setTimes(IgfsPath path,
long accessTime,
long modificationTime)
Sets last access time and last modification time for a given path.
|
void |
IgfsAsyncImpl.setTimes(IgfsPath path,
long accessTime,
long modificationTime)
Sets last access time and last modification time for a given path.
|
long |
IgfsImpl.size(IgfsPath path)
Determines size of the file denoted by provided path.
|
long |
IgfsAsyncImpl.size(IgfsPath path)
Determines size of the file denoted by provided path.
|
IgfsPathSummary |
IgfsImpl.summary(IgfsPath path)
Gets summary (total number of files, total number of directories and total length)
for a given path.
|
IgfsPathSummary |
IgfsAsyncImpl.summary(IgfsPath path)
Gets summary (total number of files, total number of directories and total length)
for a given path.
|
IgfsFileInfo |
IgfsMetaManager.synchronizeFileDual(IgfsSecondaryFileSystem fs,
IgfsPath path)
Synchronizes with secondary file system.
|
IgfsFile |
IgfsImpl.update(IgfsPath path,
Map<String,String> props)
Updates file information for the specified path.
|
IgfsFile |
IgfsAsyncImpl.update(IgfsPath path,
Map<String,String> props)
Updates file information for the specified path.
|
IgfsFileInfo |
IgfsMetaManager.updateDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
Map<String,String> props)
Update path in DUAL mode.
|
| Modifier and Type | Method and Description |
|---|---|
<T,R> R |
IgfsImpl.execute(Class<? extends IgfsTask<T,R>> taskCls,
IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeSize,
T arg)
Executes IGFS task with overridden maximum range length (see
FileSystemConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> R |
IgfsAsyncImpl.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 |
IgfsImpl.execute(Class<? extends IgfsTask<T,R>> taskCls,
IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
<T,R> R |
IgfsAsyncImpl.execute(Class<? extends IgfsTask<T,R>> taskCls,
IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
<T,R> R |
IgfsImpl.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 |
IgfsAsyncImpl.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 |
IgfsImpl.execute(IgfsTask<T,R> task,
IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
<T,R> R |
IgfsAsyncImpl.execute(IgfsTask<T,R> task,
IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
| Constructor and Description |
|---|
IgfsFileImpl(IgfsPath path,
IgfsFileInfo info,
long globalGrpBlockSize)
Constructs directory info.
|
IgfsFileImpl(IgfsPath path,
IgfsListingEntry entry,
long globalGrpSize)
Constructs file instance.
|
IgfsJobImpl(IgfsJob job,
String igfsName,
IgfsPath path,
long start,
long len,
IgfsRecordResolver rslvr) |
| Constructor and Description |
|---|
IgfsModeResolver(IgfsMode dfltMode,
List<T2<IgfsPath,IgfsMode>> modes) |
IgfsPaths(Map<String,String> props,
IgfsMode dfltMode,
List<T2<IgfsPath,IgfsMode>> pathModes)
Constructor.
|
IgfsTaskArgsImpl(String igfsName,
Collection<IgfsPath> paths,
IgfsRecordResolver recRslvr,
boolean skipNonExistentFiles,
long maxRangeLen,
T usrArg)
Constructor.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.4.0 Release Date : September 24 2015