org.apache.flink.graph.utils

Class GraphUtils

java.lang.Object

org.apache.flink.graph.utils.GraphUtils

public class GraphUtils
extends Object

Graph utilities.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GraphUtils.AddLongValue Add LongValue elements.
static class	GraphUtils.IdentityMapper<T> The identity mapper returns the input as output.
static class	GraphUtils.MapTo<I,O> Map each element to a value.
static class	GraphUtils.NonForwardingIdentityMapper<T> The identity mapper returns the input as output.

Method Summary

Modifier and Type	Method and Description
static <T> org.apache.flink.api.java.DataSet<org.apache.flink.types.LongValue>	count(org.apache.flink.api.java.DataSet<T> input) Count the number of elements in a DataSet.

Methods inherited from class java.lang.Object

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

Method Detail

count

public static <T> org.apache.flink.api.java.DataSet<org.apache.flink.types.LongValue> count(org.apache.flink.api.java.DataSet<T> input)

Count the number of elements in a DataSet.

Type Parameters:

T - element type

Parameters:

input - DataSet of elements to be counted

Returns:

count