code: def fit(self, labeled_points, epochs=10, batch_size=32, verbose=0, validation_split=0.1,
              categorical=False, nb_classes=None):
          
          rdd = lp_to_simple_rdd(labeled_points, categorical, nb_classes)
          rdd = rdd.repartition(self.num_workers)
          self._fit(rdd=rdd, epochs=epochs, batch_size=batch_size,
                    verbose=verbose, validation_split=validation_split)
docs: Train an elephas model on an RDD of LabeledPoints