| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.igfs |
Contains high performance file system processor.
|
| org.apache.ignite.internal.processors.igfs.client.meta | |
| org.apache.ignite.internal.processors.igfs.meta |
| Modifier and Type | Class and Description |
|---|---|
class |
IgfsDirectoryInfo
IGFS directory info.
|
class |
IgfsFileInfo
IGFS file info.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsEntryInfo |
IgfsEntryInfo.accessModificationTime(long accessTime,
long modificationTime)
Update access and modification time.
|
protected abstract IgfsEntryInfo |
IgfsEntryInfo.copy()
Copy file info.
|
IgfsEntryInfo |
IgfsMetaManager.fileForFragmentizer(Collection<IgniteUuid> exclude)
Gets first available file info for fragmentizer.
|
abstract IgfsEntryInfo |
IgfsEntryInfo.fileMap(IgfsFileMap fileMap)
Update file map.
|
IgfsEntryInfo |
IgfsDirectoryInfo.fileMap(IgfsFileMap fileMap)
Update file map.
|
IgfsEntryInfo |
IgfsCreateResult.info() |
IgfsEntryInfo |
IgfsDeleteResult.info() |
IgfsEntryInfo |
IgfsPathsCreateResult.info() |
IgfsEntryInfo |
IgfsMetaManager.info(IgniteUuid fileId)
Gets file info by its ID.
|
IgfsEntryInfo |
IgfsMetaManager.infoForPath(IgfsPath path)
Get info for the given path.
|
abstract IgfsEntryInfo |
IgfsEntryInfo.length(long len)
Update length.
|
IgfsEntryInfo |
IgfsDirectoryInfo.length(long len)
Update length.
|
IgfsEntryInfo |
IgfsFileInfo.listing(Map<String,IgfsListingEntry> listing)
Update listing.
|
abstract IgfsEntryInfo |
IgfsEntryInfo.listing(Map<String,IgfsListingEntry> listing)
Update listing.
|
abstract IgfsEntryInfo |
IgfsEntryInfo.lock(IgniteUuid lockId)
Lock file.
|
IgfsEntryInfo |
IgfsDirectoryInfo.lock(IgniteUuid lockId)
Lock file.
|
IgfsEntryInfo |
IgfsMetaManager.lock(IgniteUuid fileId,
boolean del)
Lock the file explicitly outside of transaction.
|
IgfsEntryInfo |
IgfsEntryInfo.properties(Map<String,String> props)
Update properties.
|
IgfsEntryInfo |
IgfsMetaManager.reserveSpace(IgniteUuid fileId,
long space,
IgfsFileAffinityRange affRange)
Reserve space for file.
|
IgfsEntryInfo |
IgfsMetaManager.synchronizeFileDual(IgfsSecondaryFileSystem fs,
IgfsPath path)
Synchronizes with secondary file system.
|
abstract IgfsEntryInfo |
IgfsEntryInfo.unlock(long modificationTime)
Unlock file.
|
IgfsEntryInfo |
IgfsDirectoryInfo.unlock(long modificationTime)
Unlock file.
|
IgfsEntryInfo |
IgfsMetaManager.updateDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
Map<String,String> props)
Update path in DUAL mode.
|
IgfsEntryInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
javax.cache.processor.EntryProcessor<IgniteUuid,IgfsEntryInfo,IgfsEntryInfo> proc)
Update file info in cache.
|
IgfsEntryInfo |
IgfsMetaManager.updateProperties(IgniteUuid fileId,
Map<String,String> props)
Update file info (file properties) in cache.
|
| Modifier and Type | Method and Description |
|---|---|
Map<IgniteUuid,IgfsEntryInfo> |
IgfsMetaManager.infos(Collection<IgniteUuid> fileIds)
Gets files details by their IDs.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsBlockLocation> |
IgfsDataManager.affinity(IgfsEntryInfo info,
long start,
long len)
Resolve affinity nodes for specified part of file.
|
Collection<IgfsBlockLocation> |
IgfsDataManager.affinity(IgfsEntryInfo info,
long start,
long len,
long maxLen)
Resolve affinity nodes for specified part of file.
|
IgfsBlockKey |
IgfsDataManager.blockKey(long blockIdx,
IgfsEntryInfo fileInfo) |
void |
IgfsDataManager.cleanBlocks(IgfsEntryInfo fileInfo,
IgfsFileAffinityRange range,
boolean cleanNonColocated)
Tries to remove blocks affected by fragmentizer.
|
IgniteInternalFuture<byte[]> |
IgfsDataManager.dataBlock(IgfsEntryInfo fileInfo,
IgfsPath path,
long blockIdx,
IgfsSecondaryFileSystemPositionedReadable secReader)
Get data block for specified file ID and block index.
|
IgniteInternalFuture<Object> |
IgfsDataManager.delete(IgfsEntryInfo fileInfo)
Delete file's data from data cache.
|
void |
IgfsDataManager.spreadBlocks(IgfsEntryInfo fileInfo,
IgfsFileAffinityRange range)
Moves all collocated blocks in range to non-colocated keys.
|
byte[] |
IgfsDataManager.storeDataBlocks(IgfsEntryInfo fileInfo,
long reservedLen,
byte[] remainder,
int remainderLen,
ByteBuffer data,
boolean flush,
IgfsFileAffinityRange affinityRange,
IgfsFileWorkerBatch batch)
Store data blocks in file.
|
byte[] |
IgfsDataManager.storeDataBlocks(IgfsEntryInfo fileInfo,
long reservedLen,
byte[] remainder,
int remainderLen,
DataInput in,
int len,
boolean flush,
IgfsFileAffinityRange affinityRange,
IgfsFileWorkerBatch batch)
Store data blocks in file.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsEntryInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
javax.cache.processor.EntryProcessor<IgniteUuid,IgfsEntryInfo,IgfsEntryInfo> proc)
Update file info in cache.
|
IgfsEntryInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
javax.cache.processor.EntryProcessor<IgniteUuid,IgfsEntryInfo,IgfsEntryInfo> proc)
Update file info in cache.
|
boolean |
IgfsPathIds.verifyIntegrity(Map<IgniteUuid,IgfsEntryInfo> infos,
boolean relaxed)
Verify that observed paths are found in provided infos in the right order.
|
| Constructor and Description |
|---|
IgfsCreateResult(IgfsEntryInfo info,
OutputStream secondaryOut)
Constructor.
|
IgfsDeleteResult(boolean success,
IgfsEntryInfo info)
Constructor.
|
IgfsFileImpl(IgfsPath path,
IgfsEntryInfo info,
long globalGrpBlockSize)
Constructs directory info.
|
IgfsListingEntry(IgfsEntryInfo fileInfo)
Constructor.
|
IgfsPathsCreateResult(List<IgfsPath> paths,
IgfsEntryInfo info)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgfsEntryInfo |
IgfsClientMetaInfoForPathCallable.call0(IgfsContext ctx)
Execute task.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsEntryInfo |
IgfsMetaUpdatePropertiesProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileReserveSpaceProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaDirectoryCreateProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileRangeUpdateProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileLockProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileCreateProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileRangeDeleteProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
| Modifier and Type | Method and Description |
|---|---|
Void |
IgfsMetaDirectoryListingRenameProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> e,
Object... args) |
Void |
IgfsMetaDirectoryListingReplaceProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> e,
Object... args) |
IgfsEntryInfo |
IgfsMetaUpdatePropertiesProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileReserveSpaceProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
Void |
IgfsMetaDirectoryListingAddProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> e,
Object... args) |
IgfsEntryInfo |
IgfsMetaDirectoryCreateProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileRangeUpdateProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
Void |
IgfsMetaFileUnlockProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
Void |
IgfsMetaUpdateTimesProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileLockProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileCreateProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
Void |
IgfsMetaDirectoryListingRemoveProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> e,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileRangeDeleteProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
Follow @ApacheIgnite
Ignite Fabric : ver. 2.6.0 Release Date : July 10 2018