edu.snu.coral.examples.beam

Class AlternatingLeastSquare.UpdateUserAndItemMatrix

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<inputT,outputT>

edu.snu.coral.compiler.frontend.beam.transform.LoopCompositeTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>>,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>>>

edu.snu.coral.examples.beam.AlternatingLeastSquare.UpdateUserAndItemMatrix

All Implemented Interfaces:

Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData

Enclosing class:

AlternatingLeastSquare

public static final class AlternatingLeastSquare.UpdateUserAndItemMatrix
extends LoopCompositeTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>>,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>>>

Composite transform that wraps the transforms inside the loop. The loop updates the user matrix and the item matrix in each iteration.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

name

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>>	expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>> itemMatrix)

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, populateDisplayData, toString, validate

Methods inherited from class java.lang.Object

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

Method Detail

expand

public org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>> expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>> itemMatrix)

Specified by:

expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>>,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<Integer,List<Double>>>>