| Package | Description |
|---|---|
| org.apache.flink.runtime.accumulators | |
| org.apache.flink.runtime.checkpoint | |
| org.apache.flink.runtime.client | |
| org.apache.flink.runtime.deployment | |
| org.apache.flink.runtime.event.task | |
| org.apache.flink.runtime.executiongraph | |
| org.apache.flink.runtime.jobmanager.accumulators | |
| org.apache.flink.runtime.messages.checkpoint |
This package contains the messages that are sent between
JobManager
and TaskManager to coordinate the checkpoint snapshots of the
distributed dataflow. |
| org.apache.flink.runtime.operators.resettable | |
| org.apache.flink.runtime.util |
| Class and Description |
|---|
| SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available
in the system class loader.
|
| Class and Description |
|---|
| SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available
in the system class loader.
|
| Class and Description |
|---|
| SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available
in the system class loader.
|
| Class and Description |
|---|
| SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available
in the system class loader.
|
| Class and Description |
|---|
| SerializableArrayList
This class extends a standard
ArrayList by implementing the
IOReadableWritable interface. |
| Class and Description |
|---|
| SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available
in the system class loader.
|
| Class and Description |
|---|
| SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available
in the system class loader.
|
| Class and Description |
|---|
| SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available
in the system 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 |
|---|
| 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.
|
| LRUCache |
| LRUCacheMap |
| NonReusingKeyGroupedIterator.ValuesIterator |
| ReusingKeyGroupedIterator.ValuesIterator |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.