org.apache.flink.graph.asm.dataset

Class Collect<T>

java.lang.Object

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

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

Type Parameters:

T - element type

All Implemented Interfaces:

DataSetAnalytic<T,List<T>>

public class Collect<T>
extends DataSetAnalyticBase<T,List<T>>

Collect the elements of a DataSet into a List.

Field Summary

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

env

Constructor Summary

Constructors

Constructor and Description
Collect()

Method Summary

Modifier and Type	Method and Description
List<T>	getResult() This method must be called after the program has executed.
Collect<T>	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 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

Collect

public Collect()

Method Detail

run

public Collect<T> 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,List<T>>

Overrides:

run in class DataSetAnalyticBase<T,List<T>>

Parameters:

input - input dataset

Returns:

this

Throws:

Exception

getResult

public List<T> 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