Class and Description |
---|
HadoopConfigLoader
This class lazily loads hadoop configuration from resettable Flink's configuration.
|
Class and Description |
---|
ResourceCounter
Counter for
ResourceProfiles . |
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 |
---|
ResourceCounter
Counter for
ResourceProfiles . |
Class and Description |
---|
ResourceCounter
Counter for
ResourceProfiles . |
Class and Description |
---|
ResourceCounter
Counter for
ResourceProfiles . |
Class and Description |
---|
ResourceCounter
Counter for
ResourceProfiles . |
Class and Description |
---|
NonClosingInputStreamDecorator
Decorator for input streams that ignores calls to
InputStream.close() . |
NonClosingOutputStreamDecorator
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.
|
ForwardingInputStream
Input stream, that wraps another input stream and forwards all method calls to the wrapped
stream.
|
ForwardingOutputStream
OutputStream , that wraps another OutputStream and forwards all method calls to
the wrapped stream. |
IntArrayList
Minimal implementation of an array-backed list of ints
|
KeyGroupedIterator |
LeaderConnectionInfo
Wrapper class for a pair of connection address and leader session ID.
|
NonReusingKeyGroupedIterator.ValuesIterator |
ResourceCounter
Counter for
ResourceProfiles . |
ReusingKeyGroupedIterator.ValuesIterator |
ZooKeeperUtils.ZkClientACLMode
ZooKeeper client ACL mode enum.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.