Interface | Description |
---|---|
Collector<T> |
Collects a record and forwards it.
|
IterableIterator<E> | |
Migration |
Tagging interface for migration related classes.
|
MutableObjectIterator<E> |
A simple iterator interface.
|
NetUtils.SocketFactory | |
Visitable<T extends Visitable<T>> |
This interface marks types as visitable during a traversal.
|
Visitor<T extends Visitable<T>> |
A visitor encapsulates functionality that is applied to each node in the process of a traversal of a tree or DAD.
|
WrappingProxy<T> |
Class | Description |
---|---|
AbstractCloseableRegistry<C extends Closeable,T> |
This is the abstract base class for registries that allow to register instances of
Closeable , which are all
closed if this registry is closed. |
AbstractID |
A statistically unique identification number.
|
CollectionUtil | |
ConfigurationUtil |
Utility for accessing deprecated
Configuration values. |
ExceptionUtils |
A collection of utility functions for dealing with exceptions and exception workflows.
|
FileUtils |
This is a utility class to deal files and directories.
|
FutureUtil | |
InstantiationUtil |
Utility class to create instances from class objects and checking failure reasons.
|
InstantiationUtil.ClassLoaderObjectInputStream |
A custom ObjectInputStream that can load classes using a specific ClassLoader.
|
IOUtils |
An utility class for I/O related functionality.
|
LongValueSequenceIterator |
The
LongValueSequenceIterator is an iterator that returns a sequence of numbers (as LongValue )s. |
MathUtils |
Collection of simple mathematical routines.
|
NetUtils | |
NumberSequenceIterator |
The
NumberSequenceIterator is an iterator that returns a sequence of numbers (as Long )s. |
OutputTag<T> |
An
OutputTag is a typed and named tag to use for tagging side outputs
of an operator. |
Preconditions |
A collection of static utility methods to validate input.
|
PropertiesUtil |
Simple utilities for getting typed values from Properties.
|
ReflectionUtil | |
ReflectionUtil.FullTypeInfo |
Container for the full type information of a type.
|
SerializedValue<T> |
This class is used to transfer (via serialization) objects whose classes are not available
in the system class loader.
|
SplittableIterator<T> |
Abstract base class for iterators that can split themselves into multiple disjoint
iterators.
|
StringBasedID |
Base class for typed IDs that are internally represented by a string.
|
StringUtils |
Utility class to convert objects into strings in vice-versa.
|
StringValueUtils |
Utility class for efficient operations on
StringValue . |
StringValueUtils.WhitespaceTokenizer |
A tokenizer for string values that uses whitespace characters as token delimiters.
|
TestLogger |
Adds automatic test name logging.
|
UnionIterator<T> | |
WrappingProxyUtil | |
XORShiftRandom |
Implement a random number generator based on the XORShift algorithm discovered by George Marsaglia.
|
Enum | Description |
---|---|
OperatingSystem |
An enumeration indicating the operating system that the JVM runs on.
|
Exception | Description |
---|---|
ConfigurationException |
Exception which occurs when creating a configuration object fails.
|
DynamicCodeLoadingException |
An exception that is thrown if the dynamic instantiation of code fails.
|
FlinkException |
Base class of all Flink-specific checked exceptions.
|
FlinkRuntimeException |
Base class of all Flink-specific unchecked exceptions.
|
StateMigrationException |
Base class for state migration related exceptions
|
TraversableOnceException |
An exception, indicating that an
Iterable can only be traversed once, but has been attempted
to traverse an additional time. |
WrappingRuntimeException |
A runtime exception that is explicitly used to wrap non-runtime exceptions.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.