org.apache.flink.graph.asm.translate.translators

Class LongValueToUnsignedIntValue

java.lang.Object

org.apache.flink.graph.asm.translate.translators.LongValueToUnsignedIntValue

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, TranslateFunction<org.apache.flink.types.LongValue,org.apache.flink.types.IntValue>

public class LongValueToUnsignedIntValue
extends Object
implements TranslateFunction<org.apache.flink.types.LongValue,org.apache.flink.types.IntValue>

Translate LongValue to IntValue.

Throws RuntimeException for integer overflow.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static long	MAX_VERTEX_COUNT

Constructor Summary

Constructors

Constructor and Description
LongValueToUnsignedIntValue()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.types.IntValue	translate(org.apache.flink.types.LongValue value, org.apache.flink.types.IntValue reuse) The translating method.

Methods inherited from class java.lang.Object

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

Field Detail

MAX_VERTEX_COUNT

public static final long MAX_VERTEX_COUNT

See Also:

Constant Field Values

Constructor Detail

LongValueToUnsignedIntValue

public LongValueToUnsignedIntValue()

Method Detail

translate

public org.apache.flink.types.IntValue translate(org.apache.flink.types.LongValue value,
                                                 org.apache.flink.types.IntValue reuse)
                                          throws Exception

Description copied from interface: TranslateFunction

The translating method. Takes an element from the input data set and transforms it into exactly one element.

Specified by:

translate in interface TranslateFunction<org.apache.flink.types.LongValue,org.apache.flink.types.IntValue>

Parameters:

value - input value.

reuse - value which may be reused for output; if reuse is null then a new output object must be instantiated and returned

Returns:

the transformed value

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.