OLD
- old graph ID typeNEW
- new graph ID typeVV
- vertex value typeEV
- edge value typepublic class TranslateGraphIds<OLD,NEW,VV,EV> extends GraphAlgorithmWrappingGraph<OLD,VV,EV,NEW,VV,EV>
parallelism
Constructor and Description |
---|
TranslateGraphIds(TranslateFunction<OLD,NEW> translator)
|
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) . |
Graph<NEW,VV,EV> |
runInternal(Graph<OLD,VV,EV> input)
The implementation of the algorithm, renamed from
GraphAlgorithm.run(Graph) . |
equals, hashCode, run
getAlgorithmName, mergeConfiguration, setParallelism
public TranslateGraphIds(TranslateFunction<OLD,NEW> translator)
translator
- implements conversion from OLD
to NEW
protected boolean canMergeConfigurationWith(GraphAlgorithmWrappingBase other)
GraphAlgorithmWrappingBase
GraphAlgorithmWrappingBase.mergeConfiguration(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase)
.canMergeConfigurationWith
in class GraphAlgorithmWrappingBase<OLD,VV,EV,Graph<NEW,VV,EV>>
other
- the algorithm with which to compare configurationGraphAlgorithmWrappingBase.mergeConfiguration(GraphAlgorithmWrappingBase)
public Graph<NEW,VV,EV> runInternal(Graph<OLD,VV,EV> input) throws Exception
GraphAlgorithmWrappingGraph
GraphAlgorithm.run(Graph)
.runInternal
in class GraphAlgorithmWrappingGraph<OLD,VV,EV,NEW,VV,EV>
input
- the input graphException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.