K
- graph ID typeVV
- vertex value typeEV
- edge value typepublic class EdgeMetrics<K extends Comparable<K>,VV,EV> extends AbstractGraphAnalytic<K,VV,EV,EdgeMetrics.Result>
Modifier and Type | Class and Description |
---|---|
static class |
EdgeMetrics.Result
Wraps edge metrics.
|
env
Constructor and Description |
---|
EdgeMetrics() |
Modifier and Type | Method and Description |
---|---|
EdgeMetrics.Result |
getResult()
This method must be called after the program has executed:
1) "run" analytics and algorithms
2) call ExecutionEnvironment.execute()
3) get analytic results
|
EdgeMetrics<K,VV,EV> |
run(Graph<K,VV,EV> input)
All
GraphAnalytic processing must be terminated by an
OutputFormat . |
EdgeMetrics<K,VV,EV> |
setParallelism(int parallelism)
Override the operator parallelism.
|
execute, execute
public EdgeMetrics<K,VV,EV> setParallelism(int parallelism)
parallelism
- operator parallelismpublic EdgeMetrics<K,VV,EV> run(Graph<K,VV,EV> input) throws Exception
GraphAnalytic
GraphAnalytic
processing must be terminated by an
OutputFormat
. Rather than obtained via accumulators rather than
returned by a DataSet
.run
in interface GraphAnalytic<K extends Comparable<K>,VV,EV,EdgeMetrics.Result>
run
in class AbstractGraphAnalytic<K extends Comparable<K>,VV,EV,EdgeMetrics.Result>
input
- input graphException
public EdgeMetrics.Result getResult()
GraphAnalytic
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.