org.apache.flink.graph.asm.degree.filter.undirected

Class MaximumDegree<K,VV,EV>

java.lang.Object

org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase<IN_K,IN_VV,IN_EV,Graph<OUT_K,OUT_VV,OUT_EV>>

org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingGraph<K,VV,EV,K,VV,EV>

org.apache.flink.graph.asm.degree.filter.undirected.MaximumDegree<K,VV,EV>

Type Parameters:

K - ID type

VV - vertex value type

EV - edge value type

All Implemented Interfaces:

GraphAlgorithm<K,VV,EV,Graph<K,VV,EV>>

public class MaximumDegree<K,VV,EV>
extends GraphAlgorithmWrappingGraph<K,VV,EV,K,VV,EV>

Removes vertices from a graph with degree greater than the given maximum. Any edge with with a source or target vertex with degree greater than the given maximum is also removed.

Field Summary

Fields inherited from class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase

parallelism

Constructor Summary

Constructors

Constructor and Description
MaximumDegree(long maximumDegree) Filter out vertices with degree greater than the given maximum.

Method Summary

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.
Graph<K,VV,EV>	runInternal(Graph<K,VV,EV> input) The implementation of the algorithm, renamed from GraphAlgorithm.run(Graph).
MaximumDegree<K,VV,EV>	setBroadcastHighDegreeVertices(boolean broadcastHighDegreeVertices) After filtering high-degree vertices this algorithm must perform joins on the original graph's vertex set and on both the source and target IDs of the edge set.
MaximumDegree<K,VV,EV>	setReduceOnTargetId(boolean reduceOnTargetId) The degree can be counted from either the edge source or target IDs.

Methods inherited from class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingGraph

equals, hashCode, run

Methods inherited from class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase

getAlgorithmName, setParallelism

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MaximumDegree

public MaximumDegree(long maximumDegree)

Filter out vertices with degree greater than the given maximum.

Parameters:

maximumDegree - maximum degree

Method Detail

setReduceOnTargetId

public MaximumDegree<K,VV,EV> setReduceOnTargetId(boolean reduceOnTargetId)

The degree can be counted from either the edge source or target IDs. By default the source IDs are counted. Reducing on target IDs may optimize the algorithm if the input edge list is sorted by target ID.

Parameters:

reduceOnTargetId - set to true if the input edge list is sorted by target ID

Returns:

this

setBroadcastHighDegreeVertices

public MaximumDegree<K,VV,EV> setBroadcastHighDegreeVertices(boolean broadcastHighDegreeVertices)

After filtering high-degree vertices this algorithm must perform joins on the original graph's vertex set and on both the source and target IDs of the edge set. These joins can be performed without shuffling data over the network if the high-degree vertices are distributed by a broadcast-hash.

Parameters:

broadcastHighDegreeVertices - set to true if the high-degree vertices should be broadcast when joining

Returns:

this

canMergeConfigurationWith

protected boolean canMergeConfigurationWith(GraphAlgorithmWrappingBase other)

Description copied from class: GraphAlgorithmWrappingBase

First test whether the algorithm configurations can be merged before the call to GraphAlgorithmWrappingBase.mergeConfiguration(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase).

Overrides:

canMergeConfigurationWith in class GraphAlgorithmWrappingBase<K,VV,EV,Graph<K,VV,EV>>

Parameters:

other - the algorithm with which to compare configuration

Returns:

true if and only if configuration can be merged and the algorithm's output can be reused

See Also:

GraphAlgorithmWrappingBase.mergeConfiguration(GraphAlgorithmWrappingBase)

mergeConfiguration

protected void mergeConfiguration(GraphAlgorithmWrappingBase other)

Description copied from class: GraphAlgorithmWrappingBase

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.

Overrides:

mergeConfiguration in class GraphAlgorithmWrappingBase<K,VV,EV,Graph<K,VV,EV>>

Parameters:

other - the algorithm from which to merge configuration

See Also:

GraphAlgorithmWrappingBase.canMergeConfigurationWith(GraphAlgorithmWrappingBase)

runInternal

public Graph<K,VV,EV> runInternal(Graph<K,VV,EV> input)
                           throws Exception

Description copied from class: GraphAlgorithmWrappingGraph

The implementation of the algorithm, renamed from GraphAlgorithm.run(Graph).

Specified by:

runInternal in class GraphAlgorithmWrappingGraph<K,VV,EV,K,VV,EV>

Parameters:

input - the input graph

Returns:

the algorithm's output

Throws:

Exception