org.apache.flink.api.java

Class Utils

java.lang.Object

org.apache.flink.api.java.Utils

@Internal
public final class Utils
extends Object

Utility class that contains helper methods to work with Java APIs.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Utils.ChecksumHashCode Accumulator of Utils.ChecksumHashCode.
static class	Utils.ChecksumHashCodeHelper<T> RichOutputFormat for Utils.ChecksumHashCode.
static class	Utils.CollectHelper<T> Utility sink function that collects elements into an accumulator, from which it they can be retrieved by the client.
static class	Utils.CountHelper<T> Utility sink function that counts elements and writes the count into an accumulator, from which it can be retrieved by the client.

Field Summary

Fields

Modifier and Type	Field and Description
static Random	RNG

Method Summary

Modifier and Type	Method and Description
static String	getCallLocationName()
static String	getCallLocationName(int depth)
static <T> String	getSerializerTree(TypeInformation<T> ti) Debugging utility to understand the hierarchy of serializers created by the Java API.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RNG

public static final Random RNG

Method Detail

getCallLocationName

public static String getCallLocationName()

getCallLocationName

public static String getCallLocationName(int depth)

getSerializerTree

public static <T> String getSerializerTree(TypeInformation<T> ti)

Debugging utility to understand the hierarchy of serializers created by the Java API. Tested in GroupReduceITCase.testGroupByGenericType()