org.apache.beam.runners.twister2.utils

Class TranslationUtils

java.lang.Object

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

public final class TranslationUtils
extends java.lang.Object

doc.

Method Summary

Modifier and Type	Method and Description
static <T> T	fromByteArray(byte[] serialized, Coder<T> coder) Utility method for deserializing a byte array using the specified coder.
static <T> org.apache.beam.sdk.util.WindowedValue<T>	fromByteArray(byte[] serialized, org.apache.beam.sdk.util.WindowedValue.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 Detail

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> org.apache.beam.sdk.util.WindowedValue<T> fromByteArray(byte[] serialized,
                                                                          org.apache.beam.sdk.util.WindowedValue.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.