snorkel.preprocess.spark.make_spark_preprocessor

snorkel.preprocess.spark.make_spark_preprocessor(mapper)[source]

Convert Mapper to be compatible with PySpark.

Parameters

mapper (Mapper) – Mapper to make compatible with PySpark

Return type

Mapper