T
- element typepublic class Collect<T> extends AbstractDataSetAnalytic<T,List<T>>
env
Constructor and Description |
---|
Collect() |
Modifier and Type | Method and Description |
---|---|
List<T> |
getResult()
This method must be called after the program has executed:
1) "run" analytics and algorithms
2) call ExecutionEnvironment.execute()
3) get analytic results
|
Collect<T> |
run(DataSet<T> input)
All
DataSetAnalytic processing must be terminated by an
OutputFormat and obtained via accumulators rather than
returned by a DataSet . |
execute, execute
public Collect<T> run(DataSet<T> input) throws Exception
DataSetAnalytic
DataSetAnalytic
processing must be terminated by an
OutputFormat
and obtained via accumulators rather than
returned by a DataSet
.public List<T> getResult()
DataSetAnalytic
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.