org.apache.flink.graph.asm.dataset

Interface DataSetAnalytic<T,R>

Type Parameters:

T - element type

R - the return type

All Known Implementing Classes:

ChecksumHashCode, Collect, Count, DataSetAnalyticBase

public interface DataSetAnalytic<T,R>

A DataSetAnalytic is similar to a CustomUnaryOperation but is terminal and results are retrieved via accumulators. A Flink program has a single point of execution. A DataSetAnalytic defers execution to the user to allow composing multiple analytics and algorithms into a single program.

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.
R	getResult() This method must be called after the program has executed.
DataSetAnalytic<T,R>	run(DataSet<T> input) All DataSetAnalytic processing must be terminated by an OutputFormat and obtained via accumulators rather than returned by a DataSet.

Method Detail

run

DataSetAnalytic<T,R> run(DataSet<T> input)
                  throws Exception

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

Parameters:

input - input dataset

Returns:

this

Throws:

Exception

execute

R execute()
   throws Exception

Execute the program and return the result.

Returns:

the result

Throws:

Exception

execute

R execute(String jobName)
   throws Exception

Execute the program and return the result.

Parameters:

jobName - the name to assign to the job

Returns:

the result

Throws:

Exception

getResult

R getResult()

This method must be called after the program has executed. 1) "run" analytics and algorithms 2) call ExecutionEnvironment.execute() 3) get analytic results

Returns:

the result