K- ID type
VV- vertex value type
EV- edge value type
R- result type
public abstract class GraphAlgorithmWrappingBase<K,VV,EV,R> extends Object implements GraphAlgorithm<K,VV,EV,R>
GraphAlgorithmtransforms an input
Graphinto an output of type
T. Subclasses of
GraphAlgorithmWrappingBasewrap the output with a
NoOpOperator. The input to the wrapped operators can be replaced when the same algorithm is run on the same input with a mergeable configuration. This allows algorithms to be composed of implicitly reusable algorithms without publicly sharing intermediate
|Modifier and Type||Field and Description|
|Constructor and Description|
|Modifier and Type||Method and Description|
First test whether the algorithm configurations can be merged before the call to
Algorithms are identified by name rather than by class to allow subclassing.
Merge the other configuration into this algorithm's after the call to
Set the parallelism for this algorithm's operators.
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public GraphAlgorithmWrappingBase<K,VV,EV,R> setParallelism(int parallelism)
Operator parallelism should be set to this given value unless processing asymptotically more data, in which case the default job parallelism should be inherited.
parallelism- operator parallelism
public String getAlgorithmName()
protected boolean canMergeConfigurationWith(GraphAlgorithmWrappingBase other)
other- the algorithm with which to compare configuration
protected void mergeConfiguration(GraphAlgorithmWrappingBase other)
canMergeConfigurationWith(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase)has checked that the configurations can be merged.
other- the algorithm from which to merge configuration
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.