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 |
---|
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 |
---|
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.
|
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 |
---|
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.
|
Class and Description |
---|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
OptionalFailure
Wrapper around an object representing either a success (with a given value) or a failure cause.
|
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 |
---|
CloseableIterator
This interface represents an
Iterator that is also AutoCloseable . |
Disposable
Interface for classes that can be disposed, i.e.
|
StateMigrationException
Base class for state migration related exceptions.
|
TernaryBoolean
A ternary boolean, which can have the values 'true', 'false', or 'undefined'.
|
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. |
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 |
---|
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.
|
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 |
---|
Collector
Collects a record and forwards it.
|
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 |
---|
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 |
---|
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.
|
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 |
---|
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 |
---|
MutableObjectIterator
A simple iterator interface.
|
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 |
---|
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 |
---|
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 |
---|
FlinkException
Base class of all Flink-specific checked exceptions.
|
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 |
---|
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.
|
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 |
---|
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 |
---|
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 |
---|
AbstractID
A statistically unique identification number.
|
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.
|
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 |
---|
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 |
---|
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 |
---|
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 |
---|
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.
|
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.
|
Class and Description |
---|
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
FlinkException
Base class of all Flink-specific checked exceptions.
|
FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
MutableObjectIterator
A simple iterator interface.
|
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 |
---|
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.
|
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 |
---|
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 |
---|
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 |
---|
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.
|
Class and Description |
---|
Collector
Collects a record and forwards it.
|
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 |
---|
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.
|
FlinkRuntimeException
Base class of all Flink-specific unchecked exceptions.
|
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 |
---|
TestLogger
Adds automatic test name logging.
|
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.
|
InstantiationUtil.ClassLoaderObjectInputStream
A custom ObjectInputStream that can load classes using a specific ClassLoader.
|
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.
|
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.
|
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.
|
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.