T
- element typeR
- the return typepublic abstract class DataSetAnalyticBase<T,R> extends Object implements DataSetAnalytic<T,R>
DataSetAnalytic
.Modifier and Type | Field and Description |
---|---|
protected ExecutionEnvironment |
env |
Constructor and Description |
---|
DataSetAnalyticBase() |
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.
|
DataSetAnalyticBase<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 . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getResult
protected ExecutionEnvironment env
public DataSetAnalyticBase<T,R> 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
.run
in interface DataSetAnalytic<T,R>
input
- input datasetException
public R execute() throws Exception
DataSetAnalytic
execute
in interface DataSetAnalytic<T,R>
Exception
public R execute(String jobName) throws Exception
DataSetAnalytic
execute
in interface DataSetAnalytic<T,R>
jobName
- the name to assign to the jobException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.