Package org.apache.flink.util

Interface Summary

Interface	Description
AutoCloseableAsync	Closeable interface which allows to close a resource in a non blocking fashion.
CloseableIterable<T>	This interface represents an iterable that is also closeable.
CloseableIterator<T>	This interface represents an Iterator that is also AutoCloseable.
Collector<T>	Collects a record and forwards it.
Disposable	Interface for classes that can be disposed, i.e.
IterableIterator<E>	An Iterator that is also Iterable (often by returning itself).
LinkedOptionalMap.ConsumerWithException<K,V,E extends Throwable>	A Consumer that throws exceptions.
MutableObjectIterator<E>	A simple iterator interface.
NetUtils.SocketFactory	A factory for a local socket from port number.
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 DAG.
WrappingProxy<T>	Interface for objects that wrap another object and proxy (possibly a subset) of the methods of that object.

Class Summary

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.
CloseableIterable.Empty<T>	Empty iterator.
CloseableIterator.IteratorAdapter<E>	Adapter from Iterator to CloseableIterator.
CollectionUtil	Simple utility to work with Java collections.
ExceptionUtils	A collection of utility functions for dealing with exceptions and exception workflows.
ExecutorUtils	Utilities for Executors.
FileUtils	This is a utility class to deal files and directories.
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.
InstantiationUtil.FailureTolerantObjectInputStream	An ObjectInputStream that ignores serialVersionUID mismatches when deserializing objects of anonymous classes or our Scala serializer classes and also replaces occurences of GenericData.Array (from Avro) by a dummy class so that the KryoSerializer can still be deserialized without Avro being on the classpath.
IOUtils	An utility class for I/O related functionality.
LambdaUtil	This class offers utility functions for Java's lambda features.
LinkedOptionalMap<K,V>	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.KeyValue<K,V>	Key-value pairs stored by the underlying map.
LinkedOptionalMap.MergeResult<K,V>	The result of merging two LinkedOptionalMaps using LinkedOptionalMap.mergeRightIntoLeft(LinkedOptionalMap, LinkedOptionalMap).
LinkedOptionalMapSerializer	LinkedOptionalMapSerializer - A serializer of LinkedOptionalMap.
LongValueSequenceIterator	The LongValueSequenceIterator is an iterator that returns a sequence of numbers (as LongValue)s.
MathUtils	Collection of simple mathematical routines.
NetUtils	Utility for various network related tasks (such as finding free ports).
NumberSequenceIterator	The NumberSequenceIterator is an iterator that returns a sequence of numbers (as Long)s.
OptionalConsumer<T>	Utility class which allows to run code depending on whether the optional has a value or is empty.
OptionalFailure<T>	Wrapper around an object representing either a success (with a given value) or a failure cause.
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	Utility for reflection operations on classes and generic type parametrization.
ReflectionUtil.FullTypeInfo	Container for the full type information of a type.
ResourceGuard	This class is a guard for shared resources with the following invariants.
SerializableObject	A simple object that only implements Serializable, so it can be used in serializable classes.
SerializedValue<T>	This class is used to transfer (via serialization) objects whose classes are not available in the system class loader.
ShutdownHookUtil	Utils class for dealing with JVM shutdown hooks.
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>	An iterator that concatenates a collection of iterators.
WrappingProxyUtil	Utilities for working with WrappingProxy.
XORShiftRandom	Implement a random number generator based on the XORShift algorithm discovered by George Marsaglia.

Enum Summary

Enum	Description
OperatingSystem	An enumeration indicating the operating system that the JVM runs on.
TernaryBoolean	A ternary boolean, which can have the values 'true', 'false', or 'undefined'.

Exception Summary

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.
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.
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.