| package org.example.vanilla | |
| import org.apache.predictionio.controller.PPreparator | |
| import org.apache.predictionio.data.storage.Event | |
| import org.apache.spark.SparkContext | |
| import org.apache.spark.rdd.RDD | |
| class Preparator | |
| extends PPreparator[TrainingData, PreparedData] { | |
| override | |
| def prepare(sc: SparkContext, trainingData: TrainingData): PreparedData = { | |
| new PreparedData(events = trainingData.events) | |
| } | |
| } | |
| class PreparedData( | |
| val events: RDD[Event] | |
| ) extends Serializable |