K
- graph ID typeVV
- vertex value typeEV
- edge value typepublic class TriangleCount<K extends Comparable<K> & CopyableValue<K>,VV,EV> extends AbstractGraphAnalytic<K,VV,EV,Long>
TriangleListing
env
Constructor and Description |
---|
TriangleCount() |
Modifier and Type | Method and Description |
---|---|
Long |
getResult()
This method must be called after the program has executed:
1) "run" analytics and algorithms
2) call ExecutionEnvironment.execute()
3) get analytic results
|
TriangleCount<K,VV,EV> |
run(Graph<K,VV,EV> input)
All
GraphAnalytic processing must be terminated by an
OutputFormat . |
TriangleCount<K,VV,EV> |
setLittleParallelism(int littleParallelism)
Override the parallelism of operators processing small amounts of data.
|
execute, execute
public TriangleCount<K,VV,EV> setLittleParallelism(int littleParallelism)
littleParallelism
- operator parallelismpublic TriangleCount<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> & CopyableValue<K>,VV,EV,Long>
run
in class AbstractGraphAnalytic<K extends Comparable<K> & CopyableValue<K>,VV,EV,Long>
input
- input graphException
public Long getResult()
GraphAnalytic
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.