code: def test_to_labeled_rdd_categorical(spark_context):
      features = np.ones((2, 10))
      labels = np.asarray([[0, 0, 1.0], [0, 1.0, 0]])
      lp_rdd = rdd_utils.to_labeled_point(
          spark_context, features, labels, True
      )
      assert lp_rdd.count() == 2
      first = lp_rdd.first()
      assert first.features.shape == (10,)
      assert first.label == 2.0
  
file_path: elephas/tests/utils/test_rdd_utils.py
imports: import numpy
  from elephas.utils import rdd_utils
label_desc: Use image node_id 2 for calling a global function with example usage: test_to_labeled_rdd_categorical(spark_context) without return types