Package org.apache.nemo.examples.beam

Interface Summary

Interface	Description
BeamWordCount.WordCountOptions	Options supported by WordCount.

Class Summary

Class	Description
AlternatingLeastSquare	Sample Alternating Least Square application.
AlternatingLeastSquare.CalculateNextMatrix	DoFn for calculating next matrix at each iteration.
AlternatingLeastSquare.CreateInitialMatrix	A DoFn that creates an initial matrix.
AlternatingLeastSquare.ParseLine	Method for parsing the input line.
AlternatingLeastSquare.TrainingDataCombiner	Combiner for the training data.
AlternatingLeastSquare.UngroupSingleVectorList	A DoFn that relays a single vector list.
AlternatingLeastSquare.UpdateUserAndItemMatrix	Composite transform that wraps the transforms inside the loop.
AlternatingLeastSquareInefficient	Sample Alternating Least Square application.
AlternatingLeastSquareInefficient.UpdateUserAndItemMatrix	Composite transform that wraps the transforms inside the loop.
BeamWordCount	An example that counts words in Shakespeare and includes Beam best practices.
BeamWordCount.CountWords	A PTransform that converts a PCollection containing lines of text into a PCollection of formatted word counts.
BeamWordCount.FormatAsTextFn	A SimpleFunction that converts a Word and Count into a printable string.
Broadcast	Sample Broadcast application.
EDGARAvgDocSize	Application for EDGAR dataset.
EDGARDocumentSuccessRate	Application for EDGAR dataset.
EDGARRequestsByCIK	Application for EDGAR dataset.
EDGARTop10BadRefererDocs	Application for EDGAR dataset.
EDGARTop10BadRefererDocs.ValueComparator<K>	Value comparator comparing the double value.
EDGARTop10Documents	Application for EDGAR dataset.
EDGARTop10Documents.ValueComparator<K>	Value comparator comparing the long value.
FloatArrayCoder	EncoderFactory for float[].
IntArrayCoder	EncoderFactory for int[].
MinimalWordCount	MinimalWordCount program from BEAM.
MultinomialLogisticRegression	Sample Multinomial Logistic Regression application.
MultinomialLogisticRegression.ApplyGradient	DoFn class that applies the gradient to the model.
MultinomialLogisticRegression.CalculateGradient	Calculate Gradient.
MultinomialLogisticRegression.CombineFunction	Combine Function for two Double arrays.
MultinomialLogisticRegression.CombineFunctionForIterable	Combine Function for Iterable of gradients.
MultinomialLogisticRegression.UpdateModel	+ Composite transform that wraps the transforms inside the loop.
NetworkTraceAnalysis	An app that analyzes data flow from network trace.
ObjectCoderForString	This coder acts like an object coder to conform the type, but is actually just a StringUtf8Coder.
PartitionWordsByLength	Partition words by length example.
PerKeyMedian	IP stat analysis example used in skew experiment.
PerPercentileAverage	Per percentile statistics application.
SimpleSumSQL	A simple SQL application.
WindowedBroadcast	A Windowed WordCount application.
WindowedWordCount	A Windowed WordCount application.
WordCount	WordCount application.
WordCountTimeOut1Sec	WordCount application, but with a timeout of 1 second.
WriteOneFilePerWindow	This class is brought from beam/examples/common/WriteOneFilePerWindow.java.
WriteOneFilePerWindow.PerWindowFiles	A FileBasedSink.FilenamePolicy produces a base file name for a write based on metadata about the data being written.