org.apache.flink.graph.library.clustering

Class TriangleListingBase<K,VV,EV,R>

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,R>

org.apache.flink.graph.library.clustering.TriangleListingBase<K,VV,EV,R>

Type Parameters:

K - graph ID type

VV - vertex value type

EV - edge value type

R - result type

All Implemented Interfaces:

GraphAlgorithm<K,VV,EV,org.apache.flink.api.java.DataSet<R>>

Direct Known Subclasses:

TriangleListing, TriangleListing

public abstract class TriangleListingBase<K,VV,EV,R>
extends GraphAlgorithmWrappingDataSet<K,VV,EV,R>

Common configuration for directed and undirected Triangle Listing algorithms.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	permuteResults
protected OptionalBoolean	sortTriangleVertices

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

parallelism

Constructor Summary

Constructors

Constructor and Description
TriangleListingBase()

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.
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.

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

equals, hashCode, run, runInternal

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

Field Detail

permuteResults

protected boolean permuteResults

sortTriangleVertices

protected OptionalBoolean sortTriangleVertices

Constructor Detail

TriangleListingBase

public TriangleListingBase()

Method Detail

setPermuteResults

public TriangleListingBase<K,VV,EV,R> setPermuteResults(boolean permuteResults)

By default only one result is output for each triangle, whether vertices are sorted or unsorted. When permutation is enabled a result is instead output for each of the six permutations of the three vertex IDs.

Parameters:

permuteResults - whether output results should be permuted

Returns:

this

setSortTriangleVertices

public 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.

Parameters:

sortTriangleVertices - whether to output each triangle's vertices in sorted order

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<R>>

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 final 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<R>>

Parameters:

other - the algorithm from which to merge configuration

See Also:

GraphAlgorithmWrappingBase.canMergeConfigurationWith(GraphAlgorithmWrappingBase)