K
- graph ID typeVV
- vertex value typeEV
- edge value typeR
- result typepublic abstract class TriangleListingBase<K,VV,EV,R> extends GraphAlgorithmWrappingDataSet<K,VV,EV,R>
Modifier and Type | Field and Description |
---|---|
protected boolean |
permuteResults |
protected OptionalBoolean |
sortTriangleVertices |
parallelism
Constructor and Description |
---|
TriangleListingBase() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
canMergeConfigurationWith(GraphAlgorithmWrappingBase other)
First test whether the algorithm configurations can be merged before the
call to
GraphAlgorithmWrappingBase.mergeConfiguration(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase) . |
protected void |
mergeConfiguration(GraphAlgorithmWrappingBase other)
Merge the other configuration into this algorithm's after the call to
GraphAlgorithmWrappingBase.canMergeConfigurationWith(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase) has checked that the configurations
can be merged. |
TriangleListingBase<K,VV,EV,R> |
setPermuteResults(boolean permuteResults)
By default only one result is output for each triangle, whether vertices
are sorted or unsorted.
|
TriangleListingBase<K,VV,EV,R> |
setSortTriangleVertices(boolean sortTriangleVertices)
Normalize the triangle listing such that for each result (K0, K1, K2)
the vertex IDs are sorted K0 < K1 < K2.
|
equals, hashCode, run, runInternal
getAlgorithmName, setParallelism
protected boolean permuteResults
protected OptionalBoolean sortTriangleVertices
public TriangleListingBase<K,VV,EV,R> setPermuteResults(boolean permuteResults)
permuteResults
- whether output results should be permutedpublic TriangleListingBase<K,VV,EV,R> setSortTriangleVertices(boolean sortTriangleVertices)
sortTriangleVertices
- whether to output each triangle's vertices in sorted orderprotected boolean canMergeConfigurationWith(GraphAlgorithmWrappingBase other)
GraphAlgorithmWrappingBase
GraphAlgorithmWrappingBase.mergeConfiguration(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase)
.canMergeConfigurationWith
in class GraphAlgorithmWrappingBase<K,VV,EV,DataSet<R>>
other
- the algorithm with which to compare configurationGraphAlgorithmWrappingBase.mergeConfiguration(GraphAlgorithmWrappingBase)
protected final void mergeConfiguration(GraphAlgorithmWrappingBase other)
GraphAlgorithmWrappingBase
GraphAlgorithmWrappingBase.canMergeConfigurationWith(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase)
has checked that the configurations
can be merged.mergeConfiguration
in class GraphAlgorithmWrappingBase<K,VV,EV,DataSet<R>>
other
- the algorithm from which to merge configurationGraphAlgorithmWrappingBase.canMergeConfigurationWith(GraphAlgorithmWrappingBase)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.