Package | Description |
---|---|
org.apache.flink.streaming.runtime.io |
Modifier and Type | Method and Description |
---|---|
BufferSpiller.SpilledBufferOrEventSequence |
BufferSpiller.rollOver()
Starts a new sequence of spilled buffers and event and returns the current sequence of spilled buffers
for reading.
|
BufferSpiller.SpilledBufferOrEventSequence |
BufferSpiller.rollOverWithNewBuffer()
Starts a new sequence of spilled buffers and event and returns the current sequence of spilled buffers
for reading.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.