Package | Description |
---|---|
org.apache.flink.streaming.runtime.io |
Modifier and Type | Class and Description |
---|---|
static class |
BufferSpiller.SpilledBufferOrEventSequence
Deprecated.
|
static class |
CachedBufferBlocker.CachedBufferOrEventSequence
This class represents a sequence of cached buffers and events, created by the
CachedBufferBlocker . |
Modifier and Type | Method and Description |
---|---|
BufferOrEventSequence |
BufferBlocker.rollOverReusingResources()
Starts a new sequence of buffers and event reusing the same resources and
returns the current sequence of buffers for reading.
|
BufferOrEventSequence |
BufferSpiller.rollOverReusingResources()
Deprecated.
NOTE: The BufferOrEventSequences created by this method all reuse the same reading memory
(to reduce overhead) and can consequently not be read concurrently with each other.
|
BufferOrEventSequence |
CachedBufferBlocker.rollOverReusingResources()
It is never reusing resources and is defaulting to
CachedBufferBlocker.rollOverWithoutReusingResources() . |
BufferOrEventSequence |
BufferBlocker.rollOverWithoutReusingResources()
Starts a new sequence of buffers and event without reusing the same resources and
returns the current sequence of buffers for reading.
|
BufferOrEventSequence |
BufferSpiller.rollOverWithoutReusingResources()
Deprecated.
The BufferOrEventSequence returned by this method is safe for concurrent consumption with
any previously returned sequence.
|
BufferOrEventSequence |
CachedBufferBlocker.rollOverWithoutReusingResources() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.