Package | Description |
---|---|
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.operators.resettable | |
org.apache.flink.runtime.operators.sort | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.util |
Class and Description |
---|
SerializedThrowable
Utility class for dealing with user-defined Throwable types that are serialized (for
example during RPC/Actor communication), but cannot be resolved with the default
class loader.
|
Class and Description |
---|
MemoryBlockIterator
The memory block iterator is an iterator that always buffers a block of elements
in memory.
|
ResettableIterator
The resettable iterator is a specialization of the iterator, allowing to reset the iterator and re-retrieve elements.
|
ResettableMutableObjectIterator
The resettable iterator is a specialization of the iterator, allowing to reset the iterator and re-retrieve elements.
|
Class and Description |
---|
KeyGroupedIterator |
Class and Description |
---|
DataOutputSerializer
A simple and efficient serializer for the
DataOutput interface. |
Class and Description |
---|
EmptyIterator
An empty iterator that never returns anything.
|
EnvironmentInformation.RevisionInformation
Revision information encapsulates information about the source code revision of the Flink
code.
|
ExecutorThreadFactory |
IntArrayList
Minimal implementation of an array-backed list of ints
|
JarFileCreator
This is an auxiliary program which creates a jar file from a set of classes.
|
KeyGroupedIterator |
LeaderConnectionInfo
Wrapper class for a pair of connection address and leader session ID.
|
LRUCache |
LRUCacheMap |
NonReusingKeyGroupedIterator.ValuesIterator |
ReusingKeyGroupedIterator.ValuesIterator |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.