org.apache.flink.examples.scala.ml

Class LinearRegression.SubUpdate

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichMapFunction<LinearRegression.Data,scala.Tuple2<LinearRegression.Params,Object>>

org.apache.flink.examples.scala.ml.LinearRegression.SubUpdate

All Implemented Interfaces:

Serializable, Function, MapFunction<LinearRegression.Data,scala.Tuple2<LinearRegression.Params,Object>>, RichFunction

Enclosing class:

LinearRegression

public static class LinearRegression.SubUpdate
extends RichMapFunction<LinearRegression.Data,scala.Tuple2<LinearRegression.Params,Object>>

Compute a single BGD type update for every parameters.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SubUpdate()

Method Summary

Modifier and Type	Method and Description
scala.Tuple2<LinearRegression.Params,Object>	map(LinearRegression.Data in) The mapping method.
void	open(Configuration parameters) Reads the parameters from a broadcast variable into a collection.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubUpdate

public SubUpdate()

Method Detail

open

public void open(Configuration parameters)

Reads the parameters from a broadcast variable into a collection.

Specified by:

open in interface RichFunction

Overrides:

open in class AbstractRichFunction

Parameters:

parameters - The configuration containing the parameters attached to the contract.

See Also:

Configuration

map

public scala.Tuple2<LinearRegression.Params,Object> map(LinearRegression.Data in)

Description copied from interface: MapFunction

The mapping method. Takes an element from the input data set and transforms it into exactly one element.

Specified by:

map in interface MapFunction<LinearRegression.Data,scala.Tuple2<LinearRegression.Params,Object>>

Specified by:

map in class RichMapFunction<LinearRegression.Data,scala.Tuple2<LinearRegression.Params,Object>>

Parameters:

in - The input value.

Returns:

The transformed value