org.apache.flink.graph.asm.dataset

Class DataSetAnalyticBase<T,R>

java.lang.Object

org.apache.flink.graph.asm.dataset.DataSetAnalyticBase<T,R>

Type Parameters:

T - element type

R - the return type

All Implemented Interfaces:

DataSetAnalytic<T,R>

Direct Known Subclasses:

ChecksumHashCode, Collect, Count

public abstract class DataSetAnalyticBase<T,R>
extends Object
implements DataSetAnalytic<T,R>

Base class for DataSetAnalytic.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.flink.api.java.ExecutionEnvironment	env

Constructor Summary

Constructors

Constructor and Description
DataSetAnalyticBase()

Method Summary

Modifier and Type	Method and Description
R	execute() Execute the program and return the result.
R	execute(String jobName) Execute the program and return the result.
DataSetAnalyticBase<T,R>	run(org.apache.flink.api.java.DataSet<T> input) All DataSetAnalytic processing must be terminated by an OutputFormat and obtained via accumulators rather than returned by a DataSet.

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.asm.dataset.DataSetAnalytic

getResult

Field Detail

env

protected org.apache.flink.api.java.ExecutionEnvironment env

Constructor Detail

DataSetAnalyticBase

public DataSetAnalyticBase()

Method Detail

run

public DataSetAnalyticBase<T,R> run(org.apache.flink.api.java.DataSet<T> input)
                             throws Exception

Description copied from interface: DataSetAnalytic

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

Specified by:

run in interface DataSetAnalytic<T,R>

Parameters:

input - input dataset

Returns:

this

Throws:

Exception

execute

public R execute()
          throws Exception

Description copied from interface: DataSetAnalytic

Execute the program and return the result.

Specified by:

execute in interface DataSetAnalytic<T,R>

Returns:

the result

Throws:

Exception

execute

public R execute(String jobName)
          throws Exception

Description copied from interface: DataSetAnalytic

Execute the program and return the result.

Specified by:

execute in interface DataSetAnalytic<T,R>

Parameters:

jobName - the name to assign to the job

Returns:

the result

Throws:

Exception