Package org.apache.flink.streaming.examples.ml

Class Summary

Class	Description
IncrementalLearningSkeleton	Skeleton for incremental machine learning algorithm consisting of a pre-computed model, which gets updated for the new inputs and new input data for which the job provides predictions.
IncrementalLearningSkeleton.FiniteNewDataSource	Feeds new data for newData.
IncrementalLearningSkeleton.FiniteTrainingDataSource	Feeds new training data for the partial model builder.
IncrementalLearningSkeleton.PartialModelBuilder	Builds up-to-date partial models on new training data.
IncrementalLearningSkeleton.Predictor	Creates newData using the model produced in batch-processing and the up-to-date partial model.