org.apache.flink.graph.utils

Class GraphUtils.AddLongValue

java.lang.Object

org.apache.flink.graph.utils.GraphUtils.AddLongValue

All Implemented Interfaces:

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

Enclosing class:

GraphUtils

public static class GraphUtils.AddLongValue
extends Object
implements org.apache.flink.api.common.functions.ReduceFunction<org.apache.flink.types.LongValue>

Add LongValue elements.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AddLongValue()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.types.LongValue	reduce(org.apache.flink.types.LongValue value1, org.apache.flink.types.LongValue value2)

Methods inherited from class java.lang.Object

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

Constructor Detail

AddLongValue

public AddLongValue()

Method Detail

reduce

public org.apache.flink.types.LongValue reduce(org.apache.flink.types.LongValue value1,
                                               org.apache.flink.types.LongValue value2)
                                        throws Exception

Specified by:

reduce in interface org.apache.flink.api.common.functions.ReduceFunction<org.apache.flink.types.LongValue>

Throws:

Exception