public interface HsFileDataIndexSpilledRegionManager extends AutoCloseable
Modifier and Type | Interface and Description |
---|---|
static interface |
HsFileDataIndexSpilledRegionManager.Factory
Factory of
HsFileDataIndexSpilledRegionManager . |
Modifier and Type | Method and Description |
---|---|
void |
appendOrOverwriteRegion(int subpartition,
org.apache.flink.runtime.io.network.partition.hybrid.HsFileDataIndexImpl.InternalRegion 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, org.apache.flink.runtime.io.network.partition.hybrid.HsFileDataIndexImpl.InternalRegion 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–2023 The Apache Software Foundation. All rights reserved.