11/* Copyright (c) 2015 & onwards. MapR Tech, Inc., All rights reserved */
22package com .mapr .db .spark .sql .api .java
33
4- import com .mapr .db .spark .condition .Predicate
54import com .mapr .db .spark .sql .GenerateSchema
65import com .mapr .db .spark .utils .MapRSpark
7- import org .ojai .DocumentConstants
8- import org .ojai .store .DocumentMutation
9-
10- import org .apache .spark .sql .{DataFrame , Dataset , Encoders , Row , SparkSession }
116import org .apache .spark .sql .types .StructType
7+ import org .apache .spark .sql .{DataFrame , Dataset , Encoders , SparkSession }
8+ import org .ojai .DocumentConstants
129
1310class MapRDBJavaSession (spark : SparkSession ) {
1411
@@ -68,10 +65,10 @@ class MapRDBJavaSession(spark: SparkSession) {
6865 }
6966
7067 def saveToMapRDB [T ](ds : Dataset [T ],
71- tableName : String ,
72- idFieldPath : String ,
73- createTable : Boolean ,
74- bulkInsert : Boolean ): Unit =
68+ tableName : String ,
69+ idFieldPath : String ,
70+ createTable : Boolean ,
71+ bulkInsert : Boolean ): Unit =
7572 MapRSpark .save(ds, tableName, idFieldPath, createTable, bulkInsert)
7673
7774 def saveToMapRDB (df : DataFrame , tableName : String ): Unit =
@@ -81,32 +78,16 @@ class MapRDBJavaSession(spark: SparkSession) {
8178 saveToMapRDB(df, tableName, DocumentConstants .ID_KEY , createTable, false )
8279
8380 def insertToMapRDB [T ](ds : Dataset [T ],
84- tableName : String ,
85- idFieldPath : String ,
86- createTable : Boolean ,
87- bulkInsert : Boolean ): Unit =
88- MapRSpark .insert(ds,
89- tableName,
90- idFieldPath,
91- createTable,
92- bulkInsert)
81+ tableName : String ,
82+ idFieldPath : String ,
83+ createTable : Boolean ,
84+ bulkInsert : Boolean ): Unit =
85+ MapRSpark .insert(ds, tableName, idFieldPath, createTable, bulkInsert)
9386
9487 def insertToMapRDB [T ](ds : Dataset [T ], tableName : String ): Unit =
9588 insertToMapRDB(ds, tableName, DocumentConstants .ID_KEY , false , false )
9689
9790 def insertToMapRDB [T ](ds : Dataset [T ], tableName : String , createTable : Boolean ): Unit =
9891 insertToMapRDB(ds, tableName, DocumentConstants .ID_KEY , createTable, false )
9992
100- def updateToMapRDB (df : DataFrame ,
101- tableName : String ,
102- mutation : (Row ) => DocumentMutation ,
103- getID : (Row ) => org.ojai.Value ): Unit =
104- MapRSpark .update(df, tableName, mutation, getID)
105-
106- def updateToMapRDB (df : DataFrame ,
107- tableName : String ,
108- mutation : (Row ) => DocumentMutation ,
109- getID : (Row ) => org.ojai.Value ,
110- condition : Predicate ): Unit =
111- MapRSpark .update(df, tableName, mutation, getID, condition)
11293}
0 commit comments