org.apache.flink.util

Class InstantiationUtil

java.lang.Object

org.apache.flink.util.InstantiationUtil

@Internal
public final class InstantiationUtil
extends Object

Utility class to create instances from class objects and checking failure reasons.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InstantiationUtil.ClassLoaderObjectInputStream A custom ObjectInputStream that can load classes using a specific ClassLoader.
static class	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.

Method Summary

Modifier and Type	Method and Description
static void	checkForInstantiation(Class<?> clazz) Performs a standard check whether the class can be instantiated by Class#newInstance().
static String	checkForInstantiationError(Class<?> clazz)
static <T extends Serializable> T	clone(T obj) Clones the given serializable object using Java serialization.
static <T extends Serializable> T	clone(T obj, ClassLoader classLoader) Clones the given serializable object using Java serialization, using the given classloader to resolve the cloned classes.
static <T extends IOReadableWritable> T	createCopyWritable(T original) Clones the given writable using the serialization.
static <T> T	deserializeFromByteArray(TypeSerializer<T> serializer, byte[] buf)
static <T> T	deserializeFromByteArray(TypeSerializer<T> serializer, T reuse, byte[] buf)
static <T> T	deserializeObject(byte[] bytes, ClassLoader cl)
static <T> T	deserializeObject(byte[] bytes, ClassLoader cl, boolean isFailureTolerant)
static <T> T	deserializeObject(InputStream in, ClassLoader cl)
static <T> T	deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant)
static boolean	hasPublicNullaryConstructor(Class<?> clazz) Checks, whether the given class has a public nullary constructor.
static <T> T	instantiate(Class<T> clazz) Creates a new instance of the given class.
static <T> T	instantiate(Class<T> clazz, Class<? super T> castTo) Creates a new instance of the given class.
static boolean	isNonStaticInnerClass(Class<?> clazz) Checks, whether the class is an inner class that is not statically accessible.
static boolean	isProperClass(Class<?> clazz) Checks, whether the class is a proper class, i.e.
static boolean	isPublic(Class<?> clazz) Checks, whether the given class is public.
static boolean	isSerializable(Object o)
static <T> T	readObjectFromConfig(Configuration config, String key, ClassLoader cl)
static byte[]	serializeObject(Object o)
static void	serializeObject(OutputStream out, Object o)
static <T> byte[]	serializeToByteArray(TypeSerializer<T> serializer, T record)
static void	writeObjectToConfig(Object o, Configuration config, String key)

Methods inherited from class java.lang.Object

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

Method Detail

instantiate

public static <T> T instantiate(Class<T> clazz,
                                Class<? super T> castTo)

Creates a new instance of the given class.

Type Parameters:

T - The generic type of the class.

Parameters:

clazz - The class to instantiate.

castTo - Optional parameter, specifying the class that the given class must be a subclass off. This argument is added to prevent class cast exceptions occurring later.

Returns:

An instance of the given class.

Throws:

RuntimeException - Thrown, if the class could not be instantiated. The exception contains a detailed message about the reason why the instantiation failed.

instantiate

public static <T> T instantiate(Class<T> clazz)

Creates a new instance of the given class.

Type Parameters:

T - The generic type of the class.

Parameters:

clazz - The class to instantiate.

Returns:

An instance of the given class.

Throws:

RuntimeException - Thrown, if the class could not be instantiated. The exception contains a detailed message about the reason why the instantiation failed.

hasPublicNullaryConstructor

public static boolean hasPublicNullaryConstructor(Class<?> clazz)

Checks, whether the given class has a public nullary constructor.

Parameters:

clazz - The class to check.

Returns:

True, if the class has a public nullary constructor, false if not.

isPublic

public static boolean isPublic(Class<?> clazz)

Checks, whether the given class is public.

Parameters:

clazz - The class to check.

Returns:

True, if the class is public, false if not.

isProperClass

public static boolean isProperClass(Class<?> clazz)

Checks, whether the class is a proper class, i.e. not abstract or an interface, and not a primitive type.

Parameters:

clazz - The class to check.

Returns:

True, if the class is a proper class, false otherwise.

isNonStaticInnerClass

public static boolean isNonStaticInnerClass(Class<?> clazz)

Checks, whether the class is an inner class that is not statically accessible. That is especially true for anonymous inner classes.

Parameters:

clazz - The class to check.

Returns:

True, if the class is a non-statically accessible inner class.

checkForInstantiation

public static void checkForInstantiation(Class<?> clazz)

Performs a standard check whether the class can be instantiated by Class#newInstance().

Parameters:

clazz - The class to check.

Throws:

RuntimeException - Thrown, if the class cannot be instantiated by Class#newInstance().

checkForInstantiationError

public static String checkForInstantiationError(Class<?> clazz)

readObjectFromConfig

public static <T> T readObjectFromConfig(Configuration config,
                                         String key,
                                         ClassLoader cl)
                                  throws IOException,
                                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObjectToConfig

public static void writeObjectToConfig(Object o,
                                       Configuration config,
                                       String key)
                                throws IOException

Throws:

IOException

serializeToByteArray

public static <T> byte[] serializeToByteArray(TypeSerializer<T> serializer,
                                              T record)
                                       throws IOException

Throws:

IOException

deserializeFromByteArray

public static <T> T deserializeFromByteArray(TypeSerializer<T> serializer,
                                             byte[] buf)
                                      throws IOException

Throws:

IOException

deserializeFromByteArray

public static <T> T deserializeFromByteArray(TypeSerializer<T> serializer,
                                             T reuse,
                                             byte[] buf)
                                      throws IOException

Throws:

IOException

deserializeObject

public static <T> T deserializeObject(byte[] bytes,
                                      ClassLoader cl)
                               throws IOException,
                                      ClassNotFoundException

Throws:

IOException

ClassNotFoundException

deserializeObject

public static <T> T deserializeObject(InputStream in,
                                      ClassLoader cl)
                               throws IOException,
                                      ClassNotFoundException

Throws:

IOException

ClassNotFoundException

deserializeObject

public static <T> T deserializeObject(byte[] bytes,
                                      ClassLoader cl,
                                      boolean isFailureTolerant)
                               throws IOException,
                                      ClassNotFoundException

Throws:

IOException

ClassNotFoundException

deserializeObject

public static <T> T deserializeObject(InputStream in,
                                      ClassLoader cl,
                                      boolean isFailureTolerant)
                               throws IOException,
                                      ClassNotFoundException

Throws:

IOException

ClassNotFoundException

serializeObject

public static byte[] serializeObject(Object o)
                              throws IOException

Throws:

IOException

serializeObject

public static void serializeObject(OutputStream out,
                                   Object o)
                            throws IOException

Throws:

IOException

isSerializable

public static boolean isSerializable(Object o)

clone

public static <T extends Serializable> T clone(T obj)
                                        throws IOException,
                                               ClassNotFoundException

Clones the given serializable object using Java serialization.

Type Parameters:

T - Type of the object to clone

Parameters:

obj - Object to clone

Returns:

Cloned object

Throws:

IOException

ClassNotFoundException

clone

public static <T extends Serializable> T clone(T obj,
                                               ClassLoader classLoader)
                                        throws IOException,
                                               ClassNotFoundException

Clones the given serializable object using Java serialization, using the given classloader to resolve the cloned classes.

Type Parameters:

T - Type of the object to clone

Parameters:

obj - Object to clone

classLoader - The classloader to resolve the classes during deserialization.

Returns:

Cloned object

Throws:

IOException

ClassNotFoundException

createCopyWritable

public static <T extends IOReadableWritable> T createCopyWritable(T original)
                                                           throws IOException

Clones the given writable using the serialization.

Type Parameters:

T - Type of the object to clone

Parameters:

original - Object to clone

Returns:

Cloned object

Throws:

IOException - Thrown is the serialization fails.