Class KMeansUpdate

  • All Implemented Interfaces:
    java.io.Serializable

    public class KMeansUpdate
    extends Update<Tuple2<java.lang.Integer,​double[]>,​Tuple2<java.lang.Integer,​Tuple2<java.lang.Integer,​double[]>>>
    See Also:
    Serialized Form
    • Constructor Detail

      • KMeansUpdate

        public KMeansUpdate()
    • Method Detail

      • process

        public Tuple2<java.lang.Integer,​double[]> process​(Tuple2<java.lang.Integer,​Tuple2<java.lang.Integer,​double[]>> input,
                                                                ML4allModel model)
        Description copied from class: Update
        Computes the new value of the global variable
        Specified by:
        process in class Update<Tuple2<java.lang.Integer,​double[]>,​Tuple2<java.lang.Integer,​Tuple2<java.lang.Integer,​double[]>>>
        Parameters:
        input - the ouput of the aggregate of the Compute
      • assign

        public ML4allModel assign​(java.util.List<Tuple2<java.lang.Integer,​double[]>> input,
                                  ML4allModel model)
        Description copied from class: Update
        Assigns the new value of the global variable to the ML4allModel
        Specified by:
        assign in class Update<Tuple2<java.lang.Integer,​double[]>,​Tuple2<java.lang.Integer,​Tuple2<java.lang.Integer,​double[]>>>
        Parameters:
        input - a list of all outputs of the process method
        Returns:
        the new ML4allModel