edu.snu.coral.examples.beam

Class AlternatingLeastSquare.ParseLine

java.lang.Object

org.apache.beam.sdk.transforms.DoFn<String,org.apache.beam.sdk.values.KV<Integer,Pair<List<Integer>,List<Double>>>>

edu.snu.coral.examples.beam.AlternatingLeastSquare.ParseLine

All Implemented Interfaces:

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

Enclosing class:

AlternatingLeastSquare

public static final class AlternatingLeastSquare.ParseLine
extends org.apache.beam.sdk.transforms.DoFn<String,org.apache.beam.sdk.values.KV<Integer,Pair<List<Integer>,List<Double>>>>

Method for parsing the input line.

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.BoundedPerElement, 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.GetRestrictionCoder, org.apache.beam.sdk.transforms.DoFn.NewTracker, org.apache.beam.sdk.transforms.DoFn.OnTimer, org.apache.beam.sdk.transforms.DoFn.OnTimerContext, org.apache.beam.sdk.transforms.DoFn.OutputReceiver<T>, org.apache.beam.sdk.transforms.DoFn.ProcessContext, org.apache.beam.sdk.transforms.DoFn.ProcessElement, org.apache.beam.sdk.transforms.DoFn.Setup, 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.TimerId, org.apache.beam.sdk.transforms.DoFn.UnboundedPerElement, org.apache.beam.sdk.transforms.DoFn.WindowedContext

Constructor Summary

Constructors

Constructor and Description
ParseLine(Boolean isUserData) Constructor for Parseline DoFn class.

Method Summary

Modifier and Type	Method and Description
void	processElement(org.apache.beam.sdk.transforms.DoFn.ProcessContext c) ProcessElement method for BEAM.

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

getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData, prepareForProcessing

Methods inherited from class java.lang.Object

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

Constructor Detail

ParseLine

public ParseLine(Boolean isUserData)

Constructor for Parseline DoFn class.

Parameters:

isUserData - flag that distinguishes user data from item data.

Method Detail

processElement

@DoFn.ProcessElement
public void processElement(org.apache.beam.sdk.transforms.DoFn.ProcessContext c)
                                         throws Exception

ProcessElement method for BEAM.

Parameters:

c - Process context.

Throws:

Exception - Exception on the way.