Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
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 | |
org.apache.flink.streaming.connectors.kafka |
Class and Description |
---|
EvictingBoundedList
This class implements a list (array based) that is physically bounded in maximum size, but can virtually grow beyond
the bounded size.
|
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.
|
EvictingBoundedList
This class implements a list (array based) that is physically bounded in maximum size, but can virtually grow beyond
the bounded size.
|
EvictingBoundedList.Function
A simple unary function that can be used to transform elements via the
EvictingBoundedList.map(Function) method. |
FatalExitExceptionHandler
Handler for uncaught exceptions that will log the exception and kill the process afterwards.
|
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 |
ZooKeeperUtils.ZkClientACLMode |
Class and Description |
---|
SerializableObject
A simple object that only implements
Serializable , so it can be used
in serializable classes. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.