public interface FileDataIndexSpilledRegionManager<T extends FileDataIndexRegionHelper.Region> extends AutoCloseable
Modifier and Type | Interface and Description |
---|---|
static interface |
FileDataIndexSpilledRegionManager.Factory<T extends FileDataIndexRegionHelper.Region>
Factory of
FileDataIndexSpilledRegionManager . |
Modifier and Type | Method and Description |
---|---|
void |
appendOrOverwriteRegion(int subpartition,
T region)
Write this region to index file.
|
void |
close()
Close this spilled region manager.
|
long |
findRegion(int subpartition,
int bufferIndex,
boolean loadToCache)
Find the region contains target bufferIndex and belong to target subpartition.
|
void appendOrOverwriteRegion(int subpartition, T region) throws IOException
subpartition
- the subpartition id of this region.region
- the region to be spilled to index file.IOException
long findRegion(int subpartition, int bufferIndex, boolean loadToCache)
subpartition
- the subpartition id that target region belong to.bufferIndex
- the buffer index that target region contains.loadToCache
- whether to load the found region into the cache.void close() throws IOException
close
in interface AutoCloseable
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.