org.apache.flink.graph

Class GraphAnalyticBase<K,VV,EV,T>

java.lang.Object

org.apache.flink.graph.GraphAnalyticBase<K,VV,EV,T>

Type Parameters:

K - key type

VV - vertex value type

EV - edge value type

T - the return type

All Implemented Interfaces:

GraphAnalytic<K,VV,EV,T>

Direct Known Subclasses:

AverageClusteringCoefficient, AverageClusteringCoefficient, ChecksumHashCode, EdgeMetrics, EdgeMetrics, GlobalClusteringCoefficient, GlobalClusteringCoefficient, TriadicCensus, TriadicCensus, VertexMetrics, VertexMetrics

public abstract class GraphAnalyticBase<K,VV,EV,T>
extends Object
implements GraphAnalytic<K,VV,EV,T>

Base class for GraphAnalytic.

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutionEnvironment	env
protected int	parallelism

Constructor Summary

Constructors

Constructor and Description
GraphAnalyticBase()

Method Summary

Modifier and Type	Method and Description
T	execute() Execute the program and return the result.
T	execute(String jobName) Execute the program and return the result.
GraphAnalytic<K,VV,EV,T>	run(Graph<K,VV,EV> input) All GraphAnalytic processing must be terminated by an OutputFormat.
GraphAnalyticBase<K,VV,EV,T>	setParallelism(int parallelism) Set the parallelism for this analytic's operators.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.graph.GraphAnalytic

getResult

Field Detail

env

protected ExecutionEnvironment env

parallelism

protected int parallelism

Constructor Detail

GraphAnalyticBase

public GraphAnalyticBase()

Method Detail

run

public GraphAnalytic<K,VV,EV,T> run(Graph<K,VV,EV> input)
                             throws Exception

Description copied from interface: GraphAnalytic

All GraphAnalytic processing must be terminated by an OutputFormat. Rather than obtained via accumulators rather than returned by a DataSet.

Specified by:

run in interface GraphAnalytic<K,VV,EV,T>

Parameters:

input - input graph

Returns:

this

Throws:

Exception

setParallelism

public GraphAnalyticBase<K,VV,EV,T> setParallelism(int parallelism)

Set the parallelism for this analytic's operators. This parameter is necessary because processing a small amount of data with high operator parallelism is slow and wasteful with memory and buffers.

Operator parallelism should be set to this given value unless processing asymptotically more data, in which case the default job parallelism should be inherited.

Parameters:

parallelism - operator parallelism

Returns:

this

execute

public T execute()
          throws Exception

Description copied from interface: GraphAnalytic

Execute the program and return the result.

Specified by:

execute in interface GraphAnalytic<K,VV,EV,T>

Returns:

the result

Throws:

Exception

execute

public T execute(String jobName)
          throws Exception

Description copied from interface: GraphAnalytic

Execute the program and return the result.

Specified by:

execute in interface GraphAnalytic<K,VV,EV,T>

Parameters:

jobName - the name to assign to the job

Returns:

the result

Throws:

Exception