Package org.apache.beam.runners.flink.translation.utils

Class SerdeUtils

java.lang.Object

org.apache.beam.runners.flink.translation.utils.SerdeUtils

public class SerdeUtils
extends Object

Util methods to help with serialization / deserialization.

Method Summary

Modifier and Type	Method	Description
static Object	deserializeObject(byte[] serialized)
static <T> org.apache.flink.core.io.SimpleVersionedSerializer<T>	getNaiveObjectSerializer()
static byte[]	serializeObject(Object obj)

Methods inherited from class java.lang.Object

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

Method Details

serializeObject

@Nonnull
public static byte[] serializeObject(@Nullable
 Object obj)
                              throws IOException

Throws:

IOException

deserializeObject

@Nullable
public static Object deserializeObject(byte[] serialized)
                                throws IOException

Throws:

IOException

getNaiveObjectSerializer

public static <T>
org.apache.flink.core.io.SimpleVersionedSerializer<T> getNaiveObjectSerializer()