| 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 | Method and Description |
|---|---|
@Nullable IgfsFileAffinityRange |
IgfsFileAffinityRange.concat(IgfsFileAffinityRange range)
Tries to concatenate this range with a given one.
|
static IgfsFileAffinityRange |
IgfsUtils.readFileAffinityRange(BinaryRawReader reader)
Read IgfsFileAffinityRange.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgfsFileAffinityRange> |
IgfsFragmentizerRequest.fragmentRanges() |
List<IgfsFileAffinityRange> |
IgfsFileMap.ranges()
Gets full list of ranges present in this map.
|
Collection<IgfsFileAffinityRange> |
IgfsFileAffinityRange.split(long maxSize)
Splits range into collection if smaller ranges with length equal to
maxSize. |
| Modifier and Type | Method and Description |
|---|---|
void |
IgfsFileMap.addRange(IgfsFileAffinityRange range)
Adds range to the list of already existing ranges.
|
void |
IgfsDataManager.cleanBlocks(IgfsEntryInfo fileInfo,
IgfsFileAffinityRange range,
boolean cleanNonColocated)
Tries to remove blocks affected by fragmentizer.
|
@Nullable IgfsFileAffinityRange |
IgfsFileAffinityRange.concat(IgfsFileAffinityRange range)
Tries to concatenate this range with a given one.
|
void |
IgfsFileMap.deleteRange(IgfsFileAffinityRange range)
Deletes range from map.
|
boolean |
IgfsFileAffinityRange.regionEqual(IgfsFileAffinityRange other)
Checks if range regions are equal.
|
IgfsEntryInfo |
IgfsMetaManager.reserveSpace(IgniteUuid fileId,
long space,
IgfsFileAffinityRange affRange)
Reserve space for file.
|
void |
IgfsDataManager.spreadBlocks(IgfsEntryInfo fileInfo,
IgfsFileAffinityRange range)
Moves all collocated blocks in range to non-colocated keys.
|
@Nullable byte[] |
IgfsDataManager.storeDataBlocks(IgfsEntryInfo fileInfo,
long reservedLen,
@Nullable byte[] remainder,
int remainderLen,
ByteBuffer data,
boolean flush,
IgfsFileAffinityRange affinityRange,
@Nullable IgfsFileWorkerBatch batch)
Store data blocks in file.
|
@Nullable byte[] |
IgfsDataManager.storeDataBlocks(IgfsEntryInfo fileInfo,
long reservedLen,
@Nullable byte[] remainder,
int remainderLen,
DataInput in,
int len,
boolean flush,
IgfsFileAffinityRange affinityRange,
@Nullable IgfsFileWorkerBatch batch)
Store data blocks in file.
|
void |
IgfsMetaManager.unlock(IgniteUuid fileId,
IgniteUuid lockId,
long modificationTime,
boolean updateSpace,
long space,
@Nullable IgfsFileAffinityRange affRange)
Remove explicit lock on file held by the current stream.
|
void |
IgfsFileMap.updateRangeStatus(IgfsFileAffinityRange range,
int status)
Updates range status in file map.
|
static void |
IgfsUtils.writeFileAffinityRange(BinaryRawWriter writer,
@Nullable IgfsFileAffinityRange affRange)
Write IgfsFileAffinityRange.
|
| Constructor and Description |
|---|
IgfsFragmentizerRequest(IgniteUuid fileId,
Collection<IgfsFileAffinityRange> fragmentRanges) |
| Constructor and Description |
|---|
IgfsClientMetaUnlockCallable(@Nullable String igfsName,
@Nullable String user,
IgniteUuid fileId,
IgniteUuid lockId,
long modificationTime,
boolean updateSpace,
long space,
IgfsFileAffinityRange affRange)
Constructor.
|
| Constructor and Description |
|---|
IgfsMetaFileRangeDeleteProcessor(IgfsFileAffinityRange range)
Constructor.
|
IgfsMetaFileRangeUpdateProcessor(IgfsFileAffinityRange range,
int status)
Constructor.
|
IgfsMetaFileReserveSpaceProcessor(long space,
IgfsFileAffinityRange affRange)
Constructor.
|
IgfsMetaFileUnlockProcessor(long modificationTime,
boolean updateSpace,
long space,
@Nullable IgfsFileAffinityRange affRange)
Constructor.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.8.0 Release Date : February 27 2020