public static class LinearRegression.SubUpdate extends RichMapFunction<LinearRegression.Data,Tuple2<LinearRegression.Params,Integer>>
Constructor and Description |
---|
SubUpdate() |
Modifier and Type | Method and Description |
---|---|
Tuple2<LinearRegression.Params,Integer> |
map(LinearRegression.Data in)
The mapping method.
|
void |
open(Configuration parameters)
Reads the parameters from a broadcast variable into a collection.
|
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public void open(Configuration parameters) throws Exception
open
in interface RichFunction
open
in class AbstractRichFunction
parameters
- The configuration containing the parameters attached to the contract.Exception
- Implementations may forward exceptions, which are caught by the runtime. When the
runtime catches an exception, it aborts the task and lets the fail-over logic
decide whether to retry the task execution.Configuration
public Tuple2<LinearRegression.Params,Integer> map(LinearRegression.Data in) throws Exception
MapFunction
map
in interface MapFunction<LinearRegression.Data,Tuple2<LinearRegression.Params,Integer>>
map
in class RichMapFunction<LinearRegression.Data,Tuple2<LinearRegression.Params,Integer>>
in
- The input value.Exception
- This method may throw exceptions. Throwing an exception will cause the operation
to fail and may trigger recovery.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.