Package org.apache.nemo.examples.beam
Class AlternatingLeastSquare.CalculateNextMatrix
- java.lang.Object
-
- org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<java.lang.Integer,org.apache.beam.sdk.values.KV<int[],float[]>>,org.apache.beam.sdk.values.KV<java.lang.Integer,float[]>>
-
- org.apache.nemo.examples.beam.AlternatingLeastSquare.CalculateNextMatrix
-
- All Implemented Interfaces:
java.io.Serializable
,org.apache.beam.sdk.transforms.display.HasDisplayData
- Enclosing class:
- AlternatingLeastSquare
public static final class AlternatingLeastSquare.CalculateNextMatrix extends org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<java.lang.Integer,org.apache.beam.sdk.values.KV<int[],float[]>>,org.apache.beam.sdk.values.KV<java.lang.Integer,float[]>>
DoFn for calculating next matrix at each iteration.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.DoFn
org.apache.beam.sdk.transforms.DoFn.AlwaysFetched, org.apache.beam.sdk.transforms.DoFn.BoundedPerElement, org.apache.beam.sdk.transforms.DoFn.BundleFinalizer, org.apache.beam.sdk.transforms.DoFn.Element, org.apache.beam.sdk.transforms.DoFn.FieldAccess, org.apache.beam.sdk.transforms.DoFn.FinishBundle, org.apache.beam.sdk.transforms.DoFn.FinishBundleContext, org.apache.beam.sdk.transforms.DoFn.GetInitialRestriction, org.apache.beam.sdk.transforms.DoFn.GetInitialWatermarkEstimatorState, org.apache.beam.sdk.transforms.DoFn.GetRestrictionCoder, org.apache.beam.sdk.transforms.DoFn.GetSize, org.apache.beam.sdk.transforms.DoFn.GetWatermarkEstimatorStateCoder, org.apache.beam.sdk.transforms.DoFn.Key, org.apache.beam.sdk.transforms.DoFn.MultiOutputReceiver, org.apache.beam.sdk.transforms.DoFn.NewTracker, org.apache.beam.sdk.transforms.DoFn.NewWatermarkEstimator, org.apache.beam.sdk.transforms.DoFn.OnTimer, org.apache.beam.sdk.transforms.DoFn.OnTimerContext, org.apache.beam.sdk.transforms.DoFn.OnTimerFamily, org.apache.beam.sdk.transforms.DoFn.OnWindowExpiration, org.apache.beam.sdk.transforms.DoFn.OnWindowExpirationContext, org.apache.beam.sdk.transforms.DoFn.OutputReceiver<T extends java.lang.Object>, org.apache.beam.sdk.transforms.DoFn.ProcessContext, org.apache.beam.sdk.transforms.DoFn.ProcessContinuation, org.apache.beam.sdk.transforms.DoFn.ProcessElement, org.apache.beam.sdk.transforms.DoFn.RequiresStableInput, org.apache.beam.sdk.transforms.DoFn.RequiresTimeSortedInput, org.apache.beam.sdk.transforms.DoFn.Restriction, org.apache.beam.sdk.transforms.DoFn.Setup, org.apache.beam.sdk.transforms.DoFn.SideInput, org.apache.beam.sdk.transforms.DoFn.SplitRestriction, org.apache.beam.sdk.transforms.DoFn.StartBundle, org.apache.beam.sdk.transforms.DoFn.StartBundleContext, org.apache.beam.sdk.transforms.DoFn.StateId, org.apache.beam.sdk.transforms.DoFn.Teardown, org.apache.beam.sdk.transforms.DoFn.TimerFamily, org.apache.beam.sdk.transforms.DoFn.TimerId, org.apache.beam.sdk.transforms.DoFn.Timestamp, org.apache.beam.sdk.transforms.DoFn.TruncateRestriction, org.apache.beam.sdk.transforms.DoFn.UnboundedPerElement, org.apache.beam.sdk.transforms.DoFn.WatermarkEstimatorState, org.apache.beam.sdk.transforms.DoFn.WindowedContext
-
-
Constructor Summary
Constructors Constructor Description CalculateNextMatrix(int numFeatures, double lambda, org.apache.beam.sdk.values.PCollectionView<java.util.Map<java.lang.Integer,float[]>> fixedMatrixView)
Constructor for CalculateNextMatrix DoFn class.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
processElement(org.apache.beam.sdk.transforms.DoFn.ProcessContext c)
ProcessElement method for BEAM.
-
-
-
Constructor Detail
-
CalculateNextMatrix
public CalculateNextMatrix(int numFeatures, double lambda, org.apache.beam.sdk.values.PCollectionView<java.util.Map<java.lang.Integer,float[]>> fixedMatrixView)
Constructor for CalculateNextMatrix DoFn class.- Parameters:
numFeatures
- number of features.lambda
- lambda.fixedMatrixView
- a PCollectionView of the fixed matrix (item / user matrix).
-
-