Package org.apache.beam.runners.twister2.utils

Class TranslationUtils

java.lang.Object

org.apache.beam.runners.twister2.utils.TranslationUtils

public final class TranslationUtils
extends Object

doc.

Method Summary

Modifier and Type	Method	Description
static <T> T	fromByteArray(byte[] serialized, Coder<T> coder)	Utility method for deserializing a byte array using the specified coder.
static <T> WindowedValue<T>	fromByteArray(byte[] serialized, WindowedValues.WindowedValueCoder<T> coder)	Utility method for deserializing a byte array using the specified coder.

Methods inherited from class java.lang.Object

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

Method Details

fromByteArray

public static <T> T fromByteArray(byte[] serialized,
 Coder<T> coder)

Utility method for deserializing a byte array using the specified coder. (From spark code)

Type Parameters:

T - Type of object to be returned.

Parameters:

serialized - bytearray to be deserialized.

coder - Coder to deserialize with.

Returns:

Deserialized object.

fromByteArray

public static <T> WindowedValue<T> fromByteArray(byte[] serialized,
 WindowedValues.WindowedValueCoder<T> coder)

Utility method for deserializing a byte array using the specified coder. (From spark code)

Type Parameters:

T - Type of object to be returned.

Parameters:

serialized - bytearray to be deserialized.

coder - Coder to deserialize with.

Returns:

Deserialized object.