org.apache.flink.graph.asm.dataset

Class Count<T>

java.lang.Object

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

org.apache.flink.graph.asm.dataset.Count<T>

Type Parameters:

T - element type

All Implemented Interfaces:

DataSetAnalytic<T,Long>

public class Count<T>
extends DataSetAnalyticBase<T,Long>

Count the number of elements in a DataSet.

Field Summary

Fields inherited from class org.apache.flink.graph.asm.dataset.DataSetAnalyticBase

env

Constructor Summary

Constructors

Constructor and Description
Count()

Method Summary

Modifier and Type	Method and Description
Long	getResult() This method must be called after the program has executed.
Count<T>	run(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 org.apache.flink.graph.asm.dataset.DataSetAnalyticBase

execute, execute

Methods inherited from class java.lang.Object

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

Constructor Detail

Count

public Count()

Method Detail

run

public Count<T> run(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,Long>

Overrides:

run in class DataSetAnalyticBase<T,Long>

Parameters:

input - input dataset

Returns:

this

Throws:

Exception

getResult

public Long getResult()

Description copied from interface: DataSetAnalytic

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