edu.snu.coral.examples.beam

Class AlternatingLeastSquare.TrainingDataCombiner

java.lang.Object

org.apache.beam.sdk.transforms.Combine.CombineFn<Pair<List<Integer>,List<Double>>,List<Pair<List<Integer>,List<Double>>>,Pair<List<Integer>,List<Double>>>

edu.snu.coral.examples.beam.AlternatingLeastSquare.TrainingDataCombiner

All Implemented Interfaces:

Serializable, org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<Pair<List<Integer>,List<Double>>,List<Pair<List<Integer>,List<Double>>>,Pair<List<Integer>,List<Double>>>, org.apache.beam.sdk.transforms.display.HasDisplayData

Enclosing class:

AlternatingLeastSquare

public static final class AlternatingLeastSquare.TrainingDataCombiner
extends org.apache.beam.sdk.transforms.Combine.CombineFn<Pair<List<Integer>,List<Double>>,List<Pair<List<Integer>,List<Double>>>,Pair<List<Integer>,List<Double>>>

Combiner for the training data.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TrainingDataCombiner()

Method Summary

Modifier and Type	Method and Description
List<Pair<List<Integer>,List<Double>>>	addInput(List<Pair<List<Integer>,List<Double>>> accumulator, Pair<List<Integer>,List<Double>> value)
List<Pair<List<Integer>,List<Double>>>	createAccumulator()
Pair<List<Integer>,List<Double>>	extractOutput(List<Pair<List<Integer>,List<Double>>> accumulator)
List<Pair<List<Integer>,List<Double>>>	mergeAccumulators(Iterable<List<Pair<List<Integer>,List<Double>>>> accumulators)

Methods inherited from class org.apache.beam.sdk.transforms.Combine.CombineFn

apply, compact, defaultValue, getOutputType

Methods inherited from class java.lang.Object

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

Constructor Detail

TrainingDataCombiner

public TrainingDataCombiner()

Method Detail

createAccumulator

public List<Pair<List<Integer>,List<Double>>> createAccumulator()

Specified by:

createAccumulator in class org.apache.beam.sdk.transforms.Combine.CombineFn<Pair<List<Integer>,List<Double>>,List<Pair<List<Integer>,List<Double>>>,Pair<List<Integer>,List<Double>>>

addInput

public List<Pair<List<Integer>,List<Double>>> addInput(List<Pair<List<Integer>,List<Double>>> accumulator,
                                                       Pair<List<Integer>,List<Double>> value)

Specified by:

addInput in class org.apache.beam.sdk.transforms.Combine.CombineFn<Pair<List<Integer>,List<Double>>,List<Pair<List<Integer>,List<Double>>>,Pair<List<Integer>,List<Double>>>

mergeAccumulators

public List<Pair<List<Integer>,List<Double>>> mergeAccumulators(Iterable<List<Pair<List<Integer>,List<Double>>>> accumulators)

Specified by:

mergeAccumulators in class org.apache.beam.sdk.transforms.Combine.CombineFn<Pair<List<Integer>,List<Double>>,List<Pair<List<Integer>,List<Double>>>,Pair<List<Integer>,List<Double>>>

extractOutput

public Pair<List<Integer>,List<Double>> extractOutput(List<Pair<List<Integer>,List<Double>>> accumulator)

Specified by:

extractOutput in class org.apache.beam.sdk.transforms.Combine.CombineFn<Pair<List<Integer>,List<Double>>,List<Pair<List<Integer>,List<Double>>>,Pair<List<Integer>,List<Double>>>