public class HsMemoryDataSpiller extends Object implements AutoCloseable
Constructor and Description |
---|
HsMemoryDataSpiller(Path dataFilePath) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this
HsMemoryDataSpiller . |
CompletableFuture<List<HsFileDataIndex.SpilledBuffer>> |
spillAsync(List<BufferWithIdentity> bufferToSpill)
Spilling buffers to disk asynchronously.
|
public HsMemoryDataSpiller(Path dataFilePath) throws IOException
IOException
public CompletableFuture<List<HsFileDataIndex.SpilledBuffer>> spillAsync(List<BufferWithIdentity> bufferToSpill)
bufferToSpill
- buffers need to be spilled, must ensure that it is sorted by
(subpartitionId, bufferIndex).public void close()
HsMemoryDataSpiller
. It means spiller will no longer accept new spilling
operation and wait for all previous spilling operation done blocking.close
in interface AutoCloseable
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.