AsterSparkFunctionDR, a subclass of AsterSparkFunction, converts source data to the type RDD[DataRow]. A function developed on the Spark side to work with Aster can derive from this class.
Run Method Signature
run (input: RDD[DataRow], sparkFunctParams: String): RDD[DataRow]