| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.igfs |
Contains high performance file system processer.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsFileInfo |
IgfsFileInfo.Builder.build()
Finishes instance construction and returns a resulting
unmodifiable instance.
|
IgfsFileInfo |
IgfsMetaManager.fileForFragmentizer(Collection<IgniteUuid> exclude)
Gets first available file info for fragmentizer.
|
abstract IgfsFileInfo |
IgfsInputStreamAdapter.fileInfo()
Gets file info for opened file.
|
IgfsFileInfo |
IgfsInputStreamImpl.fileInfo()
Gets file info for opened file.
|
IgfsFileInfo |
IgfsMetaManager.info(IgniteUuid fileId)
Gets file info by its ID.
|
IgfsFileInfo |
IgfsMetaManager.lock(IgniteUuid fileId)
Lock the file explicitly outside of transaction.
|
IgfsFileInfo |
IgfsMetaManager.lockInfo(IgfsFileInfo info)
Set lock on file info.
|
IgfsFileInfo |
IgfsMetaManager.removeIfEmpty(IgniteUuid parentId,
String fileName,
IgniteUuid fileId,
IgfsPath path,
boolean rmvLocked)
Remove file from the file system structure.
|
IgfsFileInfo |
IgfsMetaManager.synchronizeFileDual(IgfsSecondaryFileSystem fs,
IgfsPath path)
Synchronizes with secondary file system.
|
IgfsFileInfo |
IgfsMetaManager.updateDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
Map<String,String> props)
Update path in DUAL mode.
|
IgfsFileInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
IgniteClosure<IgfsFileInfo,IgfsFileInfo> c)
Update file info in cache.
|
IgfsFileInfo |
IgfsMetaManager.updateProperties(IgniteUuid parentId,
IgniteUuid fileId,
String fileName,
Map<String,String> props)
Update file info (file properties) in cache.
|
| Modifier and Type | Method and Description |
|---|---|
Map<IgniteUuid,IgfsFileInfo> |
IgfsMetaManager.infos(Collection<IgniteUuid> fileIds)
Gets files details by their IDs.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsBlockLocation> |
IgfsDataManager.affinity(IgfsFileInfo info,
long start,
long len)
Resolve affinity nodes for specified part of file.
|
Collection<IgfsBlockLocation> |
IgfsDataManager.affinity(IgfsFileInfo info,
long start,
long len,
long maxLen)
Resolve affinity nodes for specified part of file.
|
IgfsBlockKey |
IgfsDataManager.blockKey(long blockIdx,
IgfsFileInfo fileInfo) |
static IgfsFileInfo.Builder |
IgfsFileInfo.builder(IgfsFileInfo origin)
Creates a builder for the new instance of file info,
based on the specified origin.
|
void |
IgfsDataManager.cleanBlocks(IgfsFileInfo fileInfo,
IgfsFileAffinityRange range,
boolean cleanNonColocated)
Tries to remove blocks affected by fragmentizer.
|
IgniteInternalFuture<byte[]> |
IgfsDataManager.dataBlock(IgfsFileInfo fileInfo,
IgfsPath path,
long blockIdx,
IgfsSecondaryFileSystemPositionedReadable secReader)
Get data block for specified file ID and block index.
|
protected IgniteInternalFuture<byte[]> |
IgfsInputStreamImpl.dataBlock(IgfsFileInfo fileInfo,
long blockIdx)
Get data block for specified block index.
|
IgniteInternalFuture<Object> |
IgfsDataManager.delete(IgfsFileInfo fileInfo)
Delete file's data from data cache.
|
List<Long> |
IgfsDataManager.listLocalDataBlocks(IgfsFileInfo fileInfo)
Get list of local data blocks of the given file.
|
IgfsFileInfo |
IgfsMetaManager.lockInfo(IgfsFileInfo info)
Set lock on file info.
|
IgniteUuid |
IgfsMetaManager.putIfAbsent(IgniteUuid parentId,
String fileName,
IgfsFileInfo newFileInfo)
Add file into file system structure.
|
void |
IgfsDataManager.spreadBlocks(IgfsFileInfo fileInfo,
IgfsFileAffinityRange range)
Moves all colocated blocks in range to non-colocated keys.
|
byte[] |
IgfsDataManager.storeDataBlocks(IgfsFileInfo fileInfo,
long reservedLen,
byte[] remainder,
int remainderLen,
ByteBuffer data,
boolean flush,
IgfsFileAffinityRange affinityRange,
IgfsFileWorkerBatch batch)
Store data blocks in file.
|
byte[] |
IgfsDataManager.storeDataBlocks(IgfsFileInfo fileInfo,
long reservedLen,
byte[] remainder,
int remainderLen,
DataInput in,
int len,
boolean flush,
IgfsFileAffinityRange affinityRange,
IgfsFileWorkerBatch batch)
Store data blocks in file.
|
void |
IgfsMetaManager.unlock(IgfsFileInfo info,
long modificationTime)
Remove explicit lock on file held by the current thread.
|
void |
IgfsDataManager.writeClose(IgfsFileInfo fileInfo)
Notifies data manager that no further writes will be performed on stream.
|
IgniteInternalFuture<Boolean> |
IgfsDataManager.writeStart(IgfsFileInfo fileInfo)
Registers write future in igfs data manager.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsFileInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
IgniteClosure<IgfsFileInfo,IgfsFileInfo> c)
Update file info in cache.
|
IgfsFileInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
IgniteClosure<IgfsFileInfo,IgfsFileInfo> c)
Update file info in cache.
|
| Constructor and Description |
|---|
IgfsFileImpl(IgfsPath path,
IgfsFileInfo info,
long globalGrpBlockSize)
Constructs directory info.
|
IgfsFileInfo(IgfsFileInfo info)
A copy constructor, which takes all data from the specified
object field-by-field.
|
IgfsListingEntry(IgfsFileInfo fileInfo) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.1.0-incubating Release Date : May 20 2015