Class SparkInputRecordProcessorFactory
- java.lang.Object
-
- com.linkedin.venice.hadoop.spark.datawriter.recordprocessor.SparkInputRecordProcessorFactory
-
- All Implemented Interfaces:
java.io.Serializable
,org.apache.spark.api.java.function.FlatMapFunction<org.apache.spark.sql.Row,org.apache.spark.sql.Row>
public class SparkInputRecordProcessorFactory extends java.lang.Object implements org.apache.spark.api.java.function.FlatMapFunction<org.apache.spark.sql.Row,org.apache.spark.sql.Row>
A Factory class to create individualSparkInputRecordProcessor
for processing records in a Spark Dataframe.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description SparkInputRecordProcessorFactory(org.apache.spark.broadcast.Broadcast<java.util.Properties> jobProps, DataWriterAccumulators accumulators)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Iterator<org.apache.spark.sql.Row>
call(org.apache.spark.sql.Row row)
-
-
-
Constructor Detail
-
SparkInputRecordProcessorFactory
public SparkInputRecordProcessorFactory(org.apache.spark.broadcast.Broadcast<java.util.Properties> jobProps, DataWriterAccumulators accumulators)
-
-