T
- element typeR
- the return typepublic interface DataSetAnalytic<T,R>
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.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 . |
DataSetAnalytic<T,R> run(DataSet<T> input) throws Exception
DataSetAnalytic
processing must be terminated by an OutputFormat
and
obtained via accumulators rather than returned by a DataSet
.input
- input datasetException
R execute() throws Exception
Exception
R execute(String jobName) throws Exception
jobName
- the name to assign to the jobException
R getResult()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.