org.apache.flink.graph.library.metric.undirected

Class EdgeMetrics<K extends Comparable<K>,VV,EV>

java.lang.Object

org.apache.flink.graph.GraphAnalyticBase<K,VV,EV,EdgeMetrics.Result>

org.apache.flink.graph.library.metric.undirected.EdgeMetrics<K,VV,EV>

Type Parameters:

K - graph ID type

VV - vertex value type

EV - edge value type

All Implemented Interfaces:

GraphAnalytic<K,VV,EV,EdgeMetrics.Result>

public class EdgeMetrics<K extends Comparable<K>,VV,EV>
extends GraphAnalyticBase<K,VV,EV,EdgeMetrics.Result>

Compute the following edge metrics in an undirected graph. - number of triangle triplets - number of rectangle triplets - maximum number of triangle triplets - maximum number of rectangle triplets

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EdgeMetrics.Result Wraps edge metrics.

Field Summary

Fields inherited from class org.apache.flink.graph.GraphAnalyticBase

env, parallelism

Constructor Summary

Constructors

Constructor and Description
EdgeMetrics()

Method Summary

Modifier and Type	Method and Description
EdgeMetrics.Result	getResult() This method must be called after the program has executed.
EdgeMetrics<K,VV,EV>	run(Graph<K,VV,EV> input) All GraphAnalytic processing must be terminated by an OutputFormat.
EdgeMetrics<K,VV,EV>	setReduceOnTargetId(boolean reduceOnTargetId) The degree can be counted from either the edge source or target IDs.

Methods inherited from class org.apache.flink.graph.GraphAnalyticBase

execute, execute, setParallelism

Methods inherited from class java.lang.Object

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

Constructor Detail

EdgeMetrics

public EdgeMetrics()

Method Detail

setReduceOnTargetId

public EdgeMetrics<K,VV,EV> setReduceOnTargetId(boolean reduceOnTargetId)

The degree can be counted from either the edge source or target IDs. By default the source IDs are counted. Reducing on target IDs may optimize the algorithm if the input edge list is sorted by target ID.

Parameters:

reduceOnTargetId - set to true if the input edge list is sorted by target ID

Returns:

this

run

public EdgeMetrics<K,VV,EV> run(Graph<K,VV,EV> input)
                         throws Exception

Description copied from interface: GraphAnalytic

All GraphAnalytic processing must be terminated by an OutputFormat. Rather than obtained via accumulators rather than returned by a DataSet.

Specified by:

run in interface GraphAnalytic<K extends Comparable<K>,VV,EV,EdgeMetrics.Result>

Overrides:

run in class GraphAnalyticBase<K extends Comparable<K>,VV,EV,EdgeMetrics.Result>

Parameters:

input - input graph

Returns:

this

Throws:

Exception

getResult

public EdgeMetrics.Result getResult()

Description copied from interface: GraphAnalytic

This method must be called after the program has executed. 1) "run" analytics and algorithms 2) call ExecutionEnvironment.execute() 3) get analytic results

Returns:

the result