org.apache.flink.graph.asm.degree.annotate.directed

Class VertexDegrees<K,VV,EV>

java.lang.Object

org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase<K,VV,EV,org.apache.flink.api.java.DataSet<T>>

org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingDataSet<K,VV,EV,Vertex<K,VertexDegrees.Degrees>>

org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees<K,VV,EV>

Type Parameters:

K - graph label type

VV - vertex value type

EV - edge value type

All Implemented Interfaces:

GraphAlgorithm<K,VV,EV,org.apache.flink.api.java.DataSet<Vertex<K,VertexDegrees.Degrees>>>

public class VertexDegrees<K,VV,EV>
extends GraphAlgorithmWrappingDataSet<K,VV,EV,Vertex<K,VertexDegrees.Degrees>>

Annotates vertices of a directed graph with the degree, out-, and in-degree.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	VertexDegrees.Degrees Wraps the vertex degree, out-degree, and in-degree.

Field Summary

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

parallelism

Constructor Summary

Constructors

Constructor and Description
VertexDegrees()

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.
org.apache.flink.api.java.DataSet<Vertex<K,VertexDegrees.Degrees>>	runInternal(Graph<K,VV,EV> input) The implementation of the algorithm, renamed from GraphAlgorithm.run(Graph).
VertexDegrees<K,VV,EV>	setIncludeZeroDegreeVertices(boolean includeZeroDegreeVertices) By default only the edge set is processed for the computation of degree.

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

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

VertexDegrees

public VertexDegrees()

Method Detail

setIncludeZeroDegreeVertices

public VertexDegrees<K,VV,EV> setIncludeZeroDegreeVertices(boolean includeZeroDegreeVertices)

By default only the edge set is processed for the computation of degree. When this flag is set an additional join is performed against the vertex set in order to output vertices with an in-degree of zero.

Parameters:

includeZeroDegreeVertices - whether to output vertices with an in-degree of zero

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,org.apache.flink.api.java.DataSet<Vertex<K,VertexDegrees.Degrees>>>

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,org.apache.flink.api.java.DataSet<Vertex<K,VertexDegrees.Degrees>>>

Parameters:

other - the algorithm from which to merge configuration

See Also:

GraphAlgorithmWrappingBase.canMergeConfigurationWith(GraphAlgorithmWrappingBase)

runInternal

public org.apache.flink.api.java.DataSet<Vertex<K,VertexDegrees.Degrees>> runInternal(Graph<K,VV,EV> input)
                                                                               throws Exception

Description copied from class: GraphAlgorithmWrappingDataSet

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

Specified by:

runInternal in class GraphAlgorithmWrappingDataSet<K,VV,EV,Vertex<K,VertexDegrees.Degrees>>

Parameters:

input - the input graph

Returns:

the algorithm's output

Throws:

Exception