Factory class for execution environments.
The closure cleaner is a utility that tries to truncate the closure (enclosing instance) of non-static inner classes (created for inline transformation functions).
A DataSet represents a collection of elements of the same type.
A DataSet can be transformed into another DataSet by applying a transformation as for example
The ExecutionEnvironment is the context in which a program is executed.
Provides utility services for jarring and unjarring files and directories.
Utility class that contains helper methods to work with Java APIs.
Utility sink function that collects elements into an accumulator, from which it they can be retrieved by the client.
Utility sink function that counts elements and writes the count into an accumulator, from which it can be retrieved by the client.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.