Class and Description |
---|
LeaderConnectionInfo
Wrapper class for a pair of connection address and leader session ID.
|
Class and Description |
---|
LeaderConnectionInfo
Wrapper class for a pair of connection address and leader session ID.
|
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 |
---|
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 |
---|
NonClosingInputStreamDecorator
Decorator for input streams that ignores calls to
InputStream.close() . |
NonClosingOutpusStreamDecorator
Decorator for input streams that ignores calls to
OutputStream.close() . |
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.
|
ExecutorThreadFactory
A thread factory intended for use by critical thread pools.
|
ExecutorThreadFactory.Builder |
FatalExitExceptionHandler
Handler for uncaught exceptions that will log the exception and kill the process afterwards.
|
ForwardingInputStream
Input stream, that wraps another input stream and forwards all method calls to the wrapped stream.
|
ForwardingOutputStream
Output stream, that wraps another input stream and forwards all method calls to the wrapped stream.
|
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.
|
NonReusingKeyGroupedIterator.ValuesIterator |
ReusingKeyGroupedIterator.ValuesIterator |
ZooKeeperUtils.ZkClientACLMode
ZooKeeper client ACL mode enum.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.