Class and Description |
---|
AbstractID
A statistically unique identification number.
|
OptionalFailure
Wrapper around an object representing either a success (with a given value) or a failure cause.
|
Visitable
This interface marks types as visitable during a traversal.
|
Visitor
A visitor encapsulates functionality that is applied to each node in the process of a traversal
of a tree or DAG.
|
Class and Description |
---|
OptionalFailure
Wrapper around an object representing either a success (with a given value) or a failure cause.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Visitable
This interface marks types as visitable during a traversal.
|
Visitor
A visitor encapsulates functionality that is applied to each node in the process of a traversal
of a tree or DAG.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Visitable
This interface marks types as visitable during a traversal.
|
Visitor
A visitor encapsulates functionality that is applied to each node in the process of a traversal
of a tree or DAG.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
NumberSequenceIterator
The
NumberSequenceIterator is an iterator that returns a sequence of numbers (as Long )s. |
Class and Description |
---|
SplittableIterator
Abstract base class for iterators that can split themselves into multiple disjoint iterators.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
SplittableIterator
Abstract base class for iterators that can split themselves into multiple disjoint iterators.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Visitable
This interface marks types as visitable during a traversal.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Collector
Collects a record and forwards it.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Collector
Collects a record and forwards it.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Disposable
Interface for classes that can be disposed, i.e.
|
ResourceGuard
This class is a guard for shared resources with the following invariants.
|
StateMigrationException
Base class for state migration related exceptions.
|
TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
Class and Description |
---|
StateMigrationException
Base class for state migration related exceptions.
|
Class and Description |
---|
ResourceGuard
This class is a guard for shared resources with the following invariants.
|
Class and Description |
---|
AbstractCloseableRegistry
This is the abstract base class for registries that allow to register instances of
Closeable , which are all closed if this registry is closed. |
RefCounted
Interface to simply add reference counting functionality.
|
WrappingProxy
Interface for objects that wrap another object and proxy (possibly a subset) of the methods of
that object.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
RefCounted
Interface to simply add reference counting functionality.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
Class and Description |
---|
Visitable
This interface marks types as visitable during a traversal.
|
Visitor
A visitor encapsulates functionality that is applied to each node in the process of a traversal
of a tree or DAG.
|
Class and Description |
---|
Visitable
This interface marks types as visitable during a traversal.
|
Visitor
A visitor encapsulates functionality that is applied to each node in the process of a traversal
of a tree or DAG.
|
Class and Description |
---|
Visitor
A visitor encapsulates functionality that is applied to each node in the process of a traversal
of a tree or DAG.
|
Class and Description |
---|
Visitor
A visitor encapsulates functionality that is applied to each node in the process of a traversal
of a tree or DAG.
|
Class and Description |
---|
Visitable
This interface marks types as visitable during a traversal.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
OptionalFailure
Wrapper around an object representing either a success (with a given value) or a failure cause.
|
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 |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
OptionalFailure
Wrapper around an object representing either a success (with a given value) or a failure cause.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
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 |
---|
AbstractID
A statistically unique identification number.
|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
OptionalFailure
Wrapper around an object representing either a success (with a given value) or a failure cause.
|
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.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
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 |
---|
AbstractID
A statistically unique identification number.
|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
OptionalFailure
Wrapper around an object representing either a success (with a given value) or a failure cause.
|
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.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
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 |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Disposable
Interface for classes that can be disposed, i.e.
|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
MutableObjectIterator
A simple iterator interface.
|
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 |
---|
AbstractID
A statistically unique identification number.
|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
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 |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
OptionalFailure
Wrapper around an object representing either a success (with a given value) or a failure cause.
|
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 |
---|
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 |
---|
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.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Disposable
Interface for classes that can be disposed, i.e.
|
DynamicCodeLoadingException
An exception that is thrown if the dynamic instantiation of code fails.
|
ResourceGuard.Lease
A lease is issued by the
ResourceGuard as result of calls to ResourceGuard.acquireResource() . |
StateMigrationException
Base class for state migration related exceptions.
|
StringBasedID
Base class for typed IDs that are internally represented by a string.
|
Class and Description |
---|
TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
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 |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
SplittableIterator
Abstract base class for iterators that can split themselves into multiple disjoint iterators.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Collector
Collects a record and forwards it.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Disposable
Interface for classes that can be disposed, i.e.
|
SplittableIterator
Abstract base class for iterators that can split themselves into multiple disjoint iterators.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
CloseableIterable
This interface represents an iterable that is also closeable.
|
Collector
Collects a record and forwards it.
|
Disposable
Interface for classes that can be disposed, i.e.
|
FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
SerializableObject
A simple object that only implements
Serializable , so it can be used in
serializable classes. |
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 |
---|
Collector
Collects a record and forwards it.
|
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 |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Collector
Collects a record and forwards it.
|
OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
Class and Description |
---|
Collector
Collects a record and forwards it.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
WrappingRuntimeException
A runtime exception that is explicitly used to wrap non-runtime exceptions.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
MutableObjectIterator
A simple iterator interface.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Disposable
Interface for classes that can be disposed, i.e.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
Class and Description |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Class and Description |
---|
TestLogger
Adds automatic test name logging.
|
Class and Description |
---|
OperatingSystem
An enumeration indicating the operating system that the JVM runs on.
|
Class and Description |
---|
ExternalResource
Modified version of the jUnit
ExternalResource . |
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
ExternalResource
Modified version of the jUnit
ExternalResource . |
Class and Description |
---|
ExternalResource
Modified version of the jUnit
ExternalResource . |
Class and Description |
---|
AbstractID
A statistically unique identification number.
|
CloseableIterable
This interface represents an iterable that is also closeable.
|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
FlinkException
Base class of all Flink-specific checked exceptions.
|
FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
FlinkUserCodeClassLoader
This class loader accepts a custom handler if an exception occurs in
FlinkUserCodeClassLoader.loadClass(String,
boolean) . |
InstantiationUtil.ClassLoaderObjectInputStream
A custom ObjectInputStream that can load classes using a specific ClassLoader.
|
JavaGcCleanerWrapper
Java GC Cleaner wrapper.
|
LinkedOptionalMap
A LinkedOptionalMap is an order preserving map (like
LinkedHashMap ) where keys have a
unique string name, but are optionally present, and the values are optional. |
LinkedOptionalMap.ConsumerWithException
A
Consumer that throws exceptions. |
LinkedOptionalMap.KeyValue
Key-value pairs stored by the underlying map.
|
LinkedOptionalMap.MergeResult
The result of merging two
LinkedOptionalMap s using LinkedOptionalMap.mergeRightIntoLeft(LinkedOptionalMap, LinkedOptionalMap) . |
LongValueSequenceIterator
The
LongValueSequenceIterator is an iterator that returns a sequence of numbers (as
LongValue )s. |
NetUtils.SocketFactory
A factory for a local socket from port number.
|
NumberSequenceIterator
The
NumberSequenceIterator is an iterator that returns a sequence of numbers (as Long )s. |
OperatingSystem
An enumeration indicating the operating system that the JVM runs on.
|
OptionalConsumer
Utility class which allows to run code depending on whether the optional has a value or is empty.
|
OptionalFailure
Wrapper around an object representing either a success (with a given value) or a failure cause.
|
ProcessorArchitecture
The processor architecture of the this system.
|
ProcessorArchitecture.MemoryAddressSize
The memory address size of the processor.
|
ReflectionUtil.FullTypeInfo
Container for the full type information of a type.
|
ResourceGuard.Lease
A lease is issued by the
ResourceGuard as result of calls to ResourceGuard.acquireResource() . |
SerializedValue
This class is used to transfer (via serialization) objects whose classes are not available in the
system class loader.
|
SplittableIterator
Abstract base class for iterators that can split themselves into multiple disjoint iterators.
|
StateMigrationException
Base class for state migration related exceptions.
|
TemporaryClassLoaderContext
Sets a context class loader in a "try-with-resources" pattern.
|
TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
Visitable
This interface marks types as visitable during a traversal.
|
Visitor
A visitor encapsulates functionality that is applied to each node in the process of a traversal
of a tree or DAG.
|
WrappingProxy
Interface for objects that wrap another object and proxy (possibly a subset) of the methods of
that object.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
Class and Description |
---|
AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.