Class SerializationUtils
- java.lang.Object
-
- com.codedstreams.otterstreams.sql.util.SerializationUtils
-
public class SerializationUtils extends Object
Serialization utilities for distributing objects in Flink.
-
-
Constructor Summary
Constructors Constructor Description SerializationUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Tdeserialize(byte[] bytes)static <T extends Serializable>
byte[]serialize(T object)
-
-
-
Method Detail
-
serialize
public static <T extends Serializable> byte[] serialize(T object) throws IOException
- Throws:
IOException
-
deserialize
public static <T> T deserialize(byte[] bytes) throws IOException, ClassNotFoundException- Throws:
IOExceptionClassNotFoundException
-
-