Class Hierarchy
- java.lang.Object
- org.apache.nemo.examples.beam.AlternatingLeastSquare
- org.apache.nemo.examples.beam.AlternatingLeastSquareInefficient
- org.apache.nemo.examples.beam.BeamWordCount
- org.apache.nemo.examples.beam.Broadcast
- org.apache.beam.sdk.coders.Coder<T> (implements java.io.Serializable)
- org.apache.beam.sdk.coders.StructuredCoder<T>
- org.apache.beam.sdk.coders.AtomicCoder<T>
- org.apache.nemo.examples.beam.FloatArrayCoder
- org.apache.nemo.examples.beam.IntArrayCoder
- org.apache.nemo.examples.beam.ObjectCoderForString
- org.apache.beam.sdk.coders.AtomicCoder<T>
- org.apache.beam.sdk.coders.StructuredCoder<T>
- org.apache.beam.sdk.transforms.Combine.CombineFn<InputT,AccumT,OutputT>
- org.apache.nemo.examples.beam.AlternatingLeastSquare.TrainingDataCombiner
- org.apache.beam.sdk.transforms.Combine.BinaryCombineFn<V>
- org.apache.nemo.examples.beam.MultinomialLogisticRegression.CombineFunction
- org.apache.beam.sdk.transforms.DoFn<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
- org.apache.nemo.examples.beam.AlternatingLeastSquare.CalculateNextMatrix
- org.apache.nemo.examples.beam.AlternatingLeastSquare.CreateInitialMatrix
- org.apache.nemo.examples.beam.AlternatingLeastSquare.ParseLine
- org.apache.nemo.examples.beam.AlternatingLeastSquare.UngroupSingleVectorList
- org.apache.nemo.examples.beam.MultinomialLogisticRegression.ApplyGradient
- org.apache.nemo.examples.beam.MultinomialLogisticRegression.CalculateGradient
- org.apache.nemo.examples.beam.EDGARAvgDocSize
- org.apache.nemo.examples.beam.EDGARDocumentSuccessRate
- org.apache.nemo.examples.beam.EDGARRequestsByCIK
- org.apache.nemo.examples.beam.EDGARTop10BadRefererDocs
- org.apache.nemo.examples.beam.EDGARTop10BadRefererDocs.ValueComparator<K> (implements java.util.Comparator<T>, java.io.Serializable)
- org.apache.nemo.examples.beam.EDGARTop10Documents
- org.apache.nemo.examples.beam.EDGARTop10Documents.ValueComparator<K> (implements java.util.Comparator<T>, java.io.Serializable)
- org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy (implements java.io.Serializable)
- org.apache.nemo.examples.beam.WriteOneFilePerWindow.PerWindowFiles
- org.apache.beam.sdk.transforms.InferableFunction<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.transforms.ProcessFunction<InputT,OutputT>)
- org.apache.beam.sdk.transforms.SimpleFunction<InputT,OutputT> (implements org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT>)
- org.apache.nemo.examples.beam.BeamWordCount.FormatAsTextFn
- org.apache.beam.sdk.transforms.SimpleFunction<InputT,OutputT> (implements org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT>)
- org.apache.nemo.examples.beam.MinimalWordCount
- org.apache.nemo.examples.beam.MultinomialLogisticRegression
- org.apache.nemo.examples.beam.MultinomialLogisticRegression.CombineFunctionForIterable (implements org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT>)
- org.apache.nemo.examples.beam.NetworkTraceAnalysis
- org.apache.nemo.examples.beam.PartitionWordsByLength
- org.apache.nemo.examples.beam.PerKeyMedian
- org.apache.nemo.examples.beam.PerPercentileAverage
- org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
- org.apache.nemo.examples.beam.BeamWordCount.CountWords
- org.apache.nemo.compiler.frontend.beam.transform.LoopCompositeTransform<inputT,outputT> (implements java.io.Serializable)
- org.apache.nemo.examples.beam.AlternatingLeastSquare.UpdateUserAndItemMatrix
- org.apache.nemo.examples.beam.AlternatingLeastSquareInefficient.UpdateUserAndItemMatrix
- org.apache.nemo.examples.beam.MultinomialLogisticRegression.UpdateModel
- org.apache.nemo.examples.beam.WriteOneFilePerWindow
- org.apache.nemo.examples.beam.SimpleSumSQL
- org.apache.nemo.examples.beam.WindowedBroadcast
- org.apache.nemo.examples.beam.WindowedWordCount
- org.apache.nemo.examples.beam.WordCount
- org.apache.nemo.examples.beam.WordCountTimeOut1Sec
Interface Hierarchy
- org.apache.beam.sdk.transforms.display.HasDisplayData
- org.apache.beam.sdk.options.PipelineOptions
- org.apache.nemo.examples.beam.BeamWordCount.WordCountOptions
- org.apache.beam.sdk.options.PipelineOptions