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

package com.linkedin.venice.spark.datawriter.recordprocessor

Classes

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.
SparkLogicalTimestampProcessor	A Spark MapFunction that processes input Row and converts the logical timestamp in the RMD field to the actual RMD byte array if necessary.