AnsweredAssumed Answered

MapRDB Json Spark integration Type not found OJAIDocument

Question asked by surajkj on Sep 15, 2017
Latest reply on Sep 25, 2017 by arao

Hi, 

 

I am trying to create a function in scala which returns me an RDD of OJAIDocuments . But i am getting type not found when i am giving the return type. Below is my code. I am also new to Scala. 

 

package com.test.mapr.db.util

import com.mapr.db.spark.MapRDBSpark
import org.apache.spark.rdd.RDD
import com.mapr.db.spark.impl.OJAIDocument

 

object MapRDBUtil  {

/*
*
*/


def createOJAIDocuments(JsonRDD : RDD[String]) : RDD[OJAIDocument] = {

val OJAIDocumentRDD = JsonRDD.map(a => MapRDBSpark.newDocument(a))

OJAIDocumentRDD

}

}

Outcomes