| 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.
|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| Class and Description |
|---|
| FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
| 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.
|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| Class and Description |
|---|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| Class and Description |
|---|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| 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 |
|---|
| 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 |
|---|
| AbstractID
A statistically unique identification number.
|
| Class and Description |
|---|
| AbstractID
A statistically unique identification number.
|
| 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.
|
| Class and Description |
|---|
| CloseableIterator
This interface represents an
Iterator that is also AutoCloseable. |
| Class and Description |
|---|
| ConfigurationException
Exception which occurs when creating a configuration object fails.
|
| Class and Description |
|---|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| Class and Description |
|---|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| Class and Description |
|---|
| TestLogger
Adds automatic test name logging.
|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code 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 |
|---|
| CloseableIterator
This interface represents an
Iterator that is also AutoCloseable. |
| Disposable
Interface for classes that can be disposed, i.e. that have a dedicated lifecycle step to
"destroy" the object.
|
| 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.
|
| ResourceGuard.Lease
A lease is issued by the
ResourceGuard as result of calls to ResourceGuard.acquireResource(). |
| Class and Description |
|---|
| AbstractID
A statistically unique identification number.
|
| Class and Description |
|---|
| AbstractAutoCloseableRegistry
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 |
|---|
| ConfigurationException
Exception which occurs when creating a configuration object fails.
|
| 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 |
|---|
| 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 |
|---|
| 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 |
|---|
| FlinkException
Base class of all Flink-specific checked exceptions.
|
| Class and Description |
|---|
| FlinkException
Base class of all Flink-specific checked exceptions.
|
| 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 |
|---|
| Collector
Collects a record and forwards it.
|
| 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 |
|---|
| Reference
Wrapper class that allows to express whether the value is borrowed or owned.
|
| 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.
|
| 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.
|
| Class and Description |
|---|
| CloseableIterator
This interface represents an
Iterator that is also AutoCloseable. |
| Class and Description |
|---|
| StringBasedID
Base class for typed IDs that are internally represented by a string.
|
| 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. that have a dedicated lifecycle step to
"destroy" the object.
|
| 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.
|
| ConfigurationException
Exception which occurs when creating a configuration object fails.
|
| 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.
|
| 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.
|
| 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 |
|---|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| Class and Description |
|---|
| FlinkUserCodeClassLoaders.ResolveOrder
Class resolution order for Flink URL
ClassLoader. |
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| 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.
|
| TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
| 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 |
|---|
| ConfigurationException
Exception which occurs when creating a configuration object fails.
|
| 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.
|
| TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
| 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.
|
| TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
| 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.
|
| ConfigurationException
Exception which occurs when creating a configuration object fails.
|
| 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 |
|---|
| FlinkException
Base class of all Flink-specific checked 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 |
|---|
| 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 |
|---|
| AbstractID
A statistically unique identification number.
|
| Class and Description |
|---|
| AbstractID
A statistically unique identification number.
|
| Class and Description |
|---|
| AbstractID
A statistically unique identification number.
|
| AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
| Reference
Wrapper class that allows to express whether the value is borrowed or owned.
|
| 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.
|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| Class and Description |
|---|
| Collector
Collects a record and forwards it.
|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code 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 |
|---|
| 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. that have a dedicated lifecycle step to
"destroy" the object.
|
| 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.
|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| Class and Description |
|---|
| Collector
Collects a record and forwards it.
|
| MutableObjectIterator
A simple iterator interface.
|
| 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 |
|---|
| 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 |
|---|
| 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.
|
| 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 |
|---|
| 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 |
|---|
| 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 |
|---|
| 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 |
|---|
| 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 |
|---|
| 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 |
|---|
| 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 |
|---|
| 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. that have a dedicated lifecycle step to
"destroy" the object.
|
| DynamicCodeLoadingException
An exception that is thrown if the dynamic instantiation of code fails.
|
| Reference
Wrapper class that allows to express whether the value is borrowed or owned.
|
| 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.
|
| 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. |
| 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. that have a dedicated lifecycle step to
"destroy" the object.
|
| Class and Description |
|---|
| 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 |
|---|
| AutoCloseableAsync
Closeable interface which allows to close a resource in a non blocking fashion.
|
| FlinkException
Base class of all Flink-specific checked exceptions.
|
| FlinkUserCodeClassLoaders.ResolveOrder
Class resolution order for Flink URL
ClassLoader. |
| 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.
|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code 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.
|
| ConfigurationException
Exception which occurs when creating a configuration object fails.
|
| 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 |
|---|
| FlinkException
Base class of all Flink-specific checked 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. |
| 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 |
|---|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| Class and Description |
|---|
| CloseableIterator
This interface represents an
Iterator that is also AutoCloseable. |
| Disposable
Interface for classes that can be disposed, i.e. that have a dedicated lifecycle step to
"destroy" the object.
|
| 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. |
| 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 |
|---|
| AbstractID
A statistically unique identification number.
|
| SplittableIterator
Abstract base class for iterators that can split themselves into multiple disjoint iterators.
|
| TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
| 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.
|
| 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. |
| TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
| 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. that have a dedicated lifecycle step to
"destroy" the object.
|
| 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 |
|---|
| CloseableIterator
This interface represents an
Iterator that is also AutoCloseable. |
| Class and Description |
|---|
| 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 |
|---|
| 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. that have a dedicated lifecycle step to
"destroy" the object.
|
| Class and Description |
|---|
| AbstractID
A statistically unique identification number.
|
| 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 |
|---|
| 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 |
|---|
| 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.
|
| OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
| 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 |
|---|
| CloseableIterator
This interface represents an
Iterator that is also AutoCloseable. |
| Class and Description |
|---|
| MutableURLClassLoader
URL class loader that exposes the `addURL` method in URLClassLoader.
|
| Class and Description |
|---|
| FlinkUserCodeClassLoader
This class loader accepts a custom handler if an exception occurs in
FlinkUserCodeClassLoader.loadClass(String,
boolean). |
| FlinkUserCodeClassLoaders.SafetyNetWrapperClassLoader
Ensures that holding a reference on the context class loader outliving the scope of user code
does not prevent the user classloader to be garbage collected (FLINK-16245).
|
| MutableURLClassLoader
URL class loader that exposes the `addURL` method in URLClassLoader.
|
| 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 |
|---|
| 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.
|
| 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 |
|---|
| CloseableIterator
This interface represents an
Iterator that is also AutoCloseable. |
| Class and Description |
|---|
| MutableURLClassLoader
URL class loader that exposes the `addURL` method in URLClassLoader.
|
| 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 |
|---|
| 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.
|
| 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 |
|---|
| 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.
|
| 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. |
| 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 |
|---|
| 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 |
|---|
| Collector
Collects a record and forwards it.
|
| Class and Description |
|---|
| Collector
Collects a record and forwards it.
|
| 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 |
|---|
| 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. |
| CompressedSerializedValue
An extension of
SerializedValue that compresses the value after the serialization. |
| FatalExitExceptionHandler
Handler for uncaught exceptions that will log the exception and kill the process afterwards.
|
| FileLock
A file lock used for avoiding race condition among multiple threads/processes.
|
| 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). |
| FlinkUserCodeClassLoaders.ResolveOrder
Class resolution order for Flink URL
ClassLoader. |
| 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
LinkedOptionalMaps using LinkedOptionalMap.mergeRightIntoLeft(LinkedOptionalMap, LinkedOptionalMap). |
| LogLevelExtension
A extension that sets the log level for specific class/package loggers for a test.
|
| LongValueSequenceIterator
The
LongValueSequenceIterator is an iterator that returns a sequence of numbers (as
LongValue)s. |
| MutableURLClassLoader
URL class loader that exposes the `addURL` method in URLClassLoader.
|
| NetUtils.Port
Port wrapper class which holds a
FileLock until it releases. |
| 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.
|
| OutputTag
An
OutputTag is a typed and named tag to use for tagging side outputs of an operator. |
| ProcessorArchitecture
The processor architecture of the this system.
|
| ProcessorArchitecture.MemoryAddressSize
The memory address size of the processor.
|
| Reference
Wrapper class that allows to express whether the value is borrowed or owned.
|
| 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.
|
| SimpleUserCodeClassLoader
Simple
UserCodeClassLoader implementation which assumes that the provided class loader
will never be released and, hence, will never execute the release hooks. |
| 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'.
|
| UserCodeClassLoader
UserCodeClassLoader allows to register release hooks for a user code class loader.
|
| 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 |
|---|
| 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–2024 The Apache Software Foundation. All rights reserved.