Package com.linkedin.venice.spark.datawriter.recordprocessor

Class Summary

Class	Description
SparkInputRecordProcessor	An implementation of AbstractInputRecordProcessor for Spark that processes input records from the dataframe and emits an Iterator of Row with DEFAULT_SCHEMA as the schema.
SparkInputRecordProcessorFactory	A Factory class to create individual SparkInputRecordProcessor for processing records in a Spark Dataframe.