Interface | Description |
---|---|
KeyGroupedIterator<E> | |
MemoryBlockIterator |
The memory block iterator is an iterator that always buffers a block of elements
in memory.
|
ResettableIterator<E> |
The resettable iterator is a specialization of the iterator, allowing to reset the iterator and re-retrieve elements.
|
ResettableMutableObjectIterator<E> |
The resettable iterator is a specialization of the iterator, allowing to reset the iterator and re-retrieve elements.
|
Class | Description |
---|---|
AtomicDisposableReferenceCounter |
Atomic reference counter, which enters a "disposed" state after it reaches a configurable
reference count (default 0).
|
ClassLoaderUtil |
Utilities for information with respect to class loaders, specifically class loaders for
the dynamic loading of user defined classes.
|
DataInputDeserializer |
A simple and efficient deserializer for the
DataInput interface. |
DataOutputSerializer |
A simple and efficient serializer for the
DataOutput interface. |
DependencyVisitor |
This class tracks class dependency with ASM visitors.
|
EmptyIterator<E> |
An empty iterator that never returns anything.
|
EmptyMutableObjectIterator<E> |
An empty mutable object iterator that never returns anything.
|
EnvironmentInformation |
Utility class that gives access to the execution environment of the JVM, like
the executing user, startup options, or the JVM version.
|
EnvironmentInformation.RevisionInformation |
Revision information encapsulates information about the source code revision of the Flink
code.
|
EvictingBoundedList<T> |
This class implements a list (array based) that is physically bounded in maximum size, but can virtually grow beyond
the bounded size.
|
ExecutorThreadFactory | |
ExecutorUtils | |
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.
|
LeaderConnectionInfo |
Wrapper class for a pair of connection address and leader session ID.
|
LeaderRetrievalUtils |
Utility class to work with
LeaderRetrievalService class. |
LeaderRetrievalUtils.LeaderConnectionInfoListener |
Helper class which is used by the retrieveLeaderConnectionInfo method to retrieve the
leader's akka URL and the current leader session ID.
|
LeaderRetrievalUtils.LeaderGatewayListener |
Helper class which is used by the retrieveLeaderGateway method as the
LeaderRetrievalListener . |
LongArrayList |
Minimal implementation of an array-backed list of longs
|
LRUCache<V> | |
LRUCacheMap<K,V> | |
NamedThreadFactory |
Thread factory which allows to specify a thread pool name and a thread name.
|
NonReusingKeyGroupedIterator<E> |
The key grouped iterator returns a key and all values that share the same key.
|
NonReusingMutableToRegularIteratorWrapper<T> |
This class wraps a
MutableObjectIterator into a regular
Iterator . |
ProcessShutDownThread |
JVM shut down thread awaiting actor system shut down for a certain amount
of time before exiting the JVM.
|
RegularToMutableObjectIterator<T> | |
ReusingKeyGroupedIterator<E> |
The KeyValueIterator returns a key and all values that belong to the key (share the same key).
|
ReusingMutableToRegularIteratorWrapper<T> |
This class wraps a
MutableObjectIterator into a regular Iterator . |
SerializableArrayList<E extends IOReadableWritable> |
This class extends a standard
ArrayList by implementing the
IOReadableWritable interface. |
SerializableHashMap<K extends IOReadableWritable,V extends IOReadableWritable> |
This class extends a standard
HashMap by implementing the
IOReadableWritable interface. |
SerializableHashSet<T extends IOReadableWritable> |
This class extends a standard
HashSet by implementing the
IOReadableWritable interface. |
SerializableObject |
A simple object that only implements
Serializable , so it can be used
in serializable classes. |
SignalHandler |
This signal handler / signal logger is based on Apache Hadoop's org.apache.hadoop.util.SignalLogger.
|
SingleElementIterator<E> |
An
Iterator that contains only a single element. |
StandaloneUtils |
Utility class to work with Flink standalone mode.
|
ZooKeeperUtils |
Exception | 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.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.