Package org.apache.flink.core.memory
-
Interface Summary Interface Description DataInputView This interface defines a view over some memory that can be used to sequentially read the contents of the memory.DataOutputView This interface defines a view over some memory that can be used to sequentially write contents to the memory.MemorySegmentProvider The provider used for requesting and releasing batch of memory segments.MemorySegmentSource Interface describing entities that can provide memory segments.MemorySegmentWritable Provides the interface for write(Segment).SeekableDataInputView Interface marking aDataInputViewas seekable.SeekableDataOutputView Interface marking aDataOutputViewas seekable. -
Class Summary Class Description ByteArrayInputStreamWithPos Un-synchronized stream similar to Java's ByteArrayInputStream that also exposes the current position.ByteArrayOutputStreamWithPos Un-synchronized stream similar to Java's ByteArrayOutputStream that also exposes the current position.DataInputDeserializer A simple and efficient deserializer for theDataInputinterface.DataInputViewStreamWrapper Utility class that turns anInputStreaminto aDataInputView.DataOutputSerializer A simple and efficient serializer for theDataOutputinterface.DataOutputViewStreamWrapper Utility class that turns anOutputStreaminto aDataOutputView.MemorySegment This class represents a piece of memory managed by Flink.MemorySegmentFactory A factory for memory segments (MemorySegment).MemorySegmentInputStreamWithPos Un-synchronized input stream using the given memory segment.MemoryUtils Utility class for memory operations. -
Enum Summary Enum Description ManagedMemoryUseCase Use cases of managed memory.ManagedMemoryUseCase.Scope Scope at which memory is managed for a use case.