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.hadoop.fs |
Ignite Hadoop Accelerator file system API.
|
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 base on local file system.
|
org.apache.ignite.igfs.secondary.local |
Contains APIs for IGFS secondary file system.
|
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,
@Nullable 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,
@Nullable IgniteUuid affKey,
int replication,
long blockSize,
@Nullable 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,
@Nullable 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.
|
@Nullable 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,
@Nullable Map<String,String> props)
Creates directories under specified path with the specified properties.
|
IgfsMode |
IgniteFileSystem.mode(IgfsPath path)
Get mode for the given path.
|
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 modificationTime,
long accessTime)
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,
@Nullable 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,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
<T,R> R |
IgniteFileSystem.execute(IgfsTask<T,R> task,
@Nullable 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,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task.
|
<T,R> IgniteFuture<R> |
IgniteFileSystem.executeAsync(Class<? extends IgfsTask<T,R>> taskCls,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes IGFS task asynchronously with overridden maximum range length (see
FileSystemConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> IgniteFuture<R> |
IgniteFileSystem.executeAsync(Class<? extends IgfsTask<T,R>> taskCls,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task asynchronously.
|
<T,R> IgniteFuture<R> |
IgniteFileSystem.executeAsync(IgfsTask<T,R> task,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
boolean skipNonExistentFiles,
long maxRangeLen,
T arg)
Executes IGFS task asynchronously with overridden maximum range length (see
FileSystemConfiguration.getMaximumTaskRangeLength() for more information). |
<T,R> IgniteFuture<R> |
IgniteFileSystem.executeAsync(IgfsTask<T,R> task,
@Nullable IgfsRecordResolver rslvr,
Collection<IgfsPath> paths,
T arg)
Executes IGFS task asynchronously.
|
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 |
---|---|
@Nullable 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 |
---|---|
Collection<IgfsPath> |
IgniteHadoopIgfsSecondaryFileSystem.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
Modifier and Type | Method and Description |
---|---|
Collection<IgfsBlockLocation> |
IgniteHadoopIgfsSecondaryFileSystem.affinity(IgfsPath path,
long start,
long len,
long maxLen)
Get affinity block locations for data blocks of the file.
|
OutputStream |
IgniteHadoopIgfsSecondaryFileSystem.append(IgfsPath path,
int bufSize,
boolean create,
@Nullable Map<String,String> props)
Opens an output stream to an existing file for appending data.
|
OutputStream |
IgniteHadoopIgfsSecondaryFileSystem.create(IgfsPath path,
boolean overwrite)
Creates a file and opens it for writing.
|
OutputStream |
IgniteHadoopIgfsSecondaryFileSystem.create(IgfsPath path,
int bufSize,
boolean overwrite,
int replication,
long blockSize,
@Nullable Map<String,String> props)
Creates a file and opens it for writing.
|
boolean |
IgniteHadoopIgfsSecondaryFileSystem.delete(IgfsPath path,
boolean recursive)
Deletes file.
|
boolean |
IgniteHadoopIgfsSecondaryFileSystem.exists(IgfsPath path)
Checks if the specified path exists.
|
IgfsFile |
IgniteHadoopIgfsSecondaryFileSystem.info(IgfsPath path)
Gets file information for the specified path.
|
Collection<IgfsFile> |
IgniteHadoopIgfsSecondaryFileSystem.listFiles(IgfsPath path)
Lists files under the specified path.
|
Collection<IgfsPath> |
IgniteHadoopIgfsSecondaryFileSystem.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
void |
IgniteHadoopIgfsSecondaryFileSystem.mkdirs(IgfsPath path)
Creates directories under specified path.
|
void |
IgniteHadoopIgfsSecondaryFileSystem.mkdirs(IgfsPath path,
@Nullable Map<String,String> props)
Creates directories under specified path with the specified properties.
|
IgfsSecondaryFileSystemPositionedReadable |
IgniteHadoopIgfsSecondaryFileSystem.open(IgfsPath path,
int bufSize)
Opens a file for reading.
|
void |
IgniteHadoopIgfsSecondaryFileSystem.rename(IgfsPath src,
IgfsPath dest)
Renames/moves a file.
|
void |
IgniteHadoopIgfsSecondaryFileSystem.setTimes(IgfsPath path,
long modificationTime,
long accessTime)
Set times for the given path.
|
@Nullable IgfsFile |
IgniteHadoopIgfsSecondaryFileSystem.update(IgfsPath path,
Map<String,String> props)
Updates file information for the specified path.
|
Modifier and Type | Field and Description |
---|---|
static IgfsPath |
IgfsPath.ROOT
Root path.
|
Modifier and Type | Method and Description |
---|---|
@Nullable IgfsPath |
IgfsPath.parent()
Returns the parent of a path or
null if at root. |
IgfsPath |
IgfsFile.path()
Gets path to file.
|
IgfsPath |
IgfsPathSummary.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.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 @Nullable 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 |
---|---|
Collection<IgfsBlockLocation> |
IgfsSecondaryFileSystem.affinity(IgfsPath path,
long start,
long len,
long maxLen)
Get affinity block locations for data blocks of the file.
|
OutputStream |
IgfsSecondaryFileSystem.append(IgfsPath path,
int bufSize,
boolean create,
@Nullable 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,
@Nullable 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,
@Nullable 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.
|
void |
IgfsSecondaryFileSystem.setTimes(IgfsPath path,
long modificationTime,
long accessTime)
Set times for the given path.
|
IgfsFile |
IgfsSecondaryFileSystem.update(IgfsPath path,
Map<String,String> props)
Updates file information for the specified path.
|
Modifier and Type | Method and Description |
---|---|
Collection<IgfsPath> |
LocalIgfsSecondaryFileSystem.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
Modifier and Type | Method and Description |
---|---|
Collection<IgfsBlockLocation> |
LocalIgfsSecondaryFileSystem.affinity(IgfsPath path,
long start,
long len,
long maxLen)
Get affinity block locations for data blocks of the file.
|
OutputStream |
LocalIgfsSecondaryFileSystem.append(IgfsPath path,
int bufSize,
boolean create,
@Nullable Map<String,String> props)
Opens an output stream to an existing file for appending data.
|
OutputStream |
LocalIgfsSecondaryFileSystem.create(IgfsPath path,
boolean overwrite)
Creates a file and opens it for writing.
|
OutputStream |
LocalIgfsSecondaryFileSystem.create(IgfsPath path,
int bufSize,
boolean overwrite,
int replication,
long blockSize,
@Nullable Map<String,String> props)
Creates a file and opens it for writing.
|
boolean |
LocalIgfsSecondaryFileSystem.delete(IgfsPath path,
boolean recursive)
Deletes file.
|
boolean |
LocalIgfsSecondaryFileSystem.exists(IgfsPath path)
Checks if the specified path exists.
|
IgfsFile |
LocalIgfsSecondaryFileSystem.info(IgfsPath path)
Gets file information for the specified path.
|
Collection<IgfsFile> |
LocalIgfsSecondaryFileSystem.listFiles(IgfsPath path)
Lists files under the specified path.
|
Collection<IgfsPath> |
LocalIgfsSecondaryFileSystem.listPaths(IgfsPath path)
Lists file paths under the specified path.
|
void |
LocalIgfsSecondaryFileSystem.mkdirs(IgfsPath path)
Creates directories under specified path.
|
void |
LocalIgfsSecondaryFileSystem.mkdirs(IgfsPath path,
@Nullable Map<String,String> props)
Creates directories under specified path with the specified properties.
|
IgfsSecondaryFileSystemPositionedReadable |
LocalIgfsSecondaryFileSystem.open(IgfsPath path,
int bufSize)
Opens a file for reading.
|
void |
LocalIgfsSecondaryFileSystem.rename(IgfsPath src,
IgfsPath dest)
Renames/moves a file.
|
void |
LocalIgfsSecondaryFileSystem.setTimes(IgfsPath path,
long modificationTime,
long accessTime)
Set times for the given path.
|
@Nullable IgfsFile |
LocalIgfsSecondaryFileSystem.update(IgfsPath path,
Map<String,String> props)
Updates file information for the specified path.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.2 Release Date : February 6 2019