Skip to content

Commit e86c2a9

Browse files
author
Jacky Li
committed
adding parser for bulkload
1 parent ecc9708 commit e86c2a9

18 files changed

+26
-1751
lines changed

sql/hbase/src/main/scala/org/apache/spark/sql/hbase/HBaseCatalog.scala

Lines changed: 0 additions & 318 deletions
This file was deleted.

sql/hbase/src/main/scala/org/apache/spark/sql/hbase/HBaseLogicalPlan.scala

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package org.apache.spark.sql.hbase.logical
22

3-
import org.apache.spark.sql.catalyst.plans.logical.{LeafNode, LogicalPlan, Command}
4-
import org.apache.spark.sql.hbase.HBaseRelation
5-
3+
import org.apache.spark.sql.catalyst.plans.logical.{UnaryNode, LeafNode, LogicalPlan, Command}
4+
//import org.apache.spark.sql.hbase.HBaseRelation
5+
/*
66
case class CreateHBaseTablePlan(tableName: String,
77
nameSpace: String,
88
hbaseTable: String,
@@ -20,10 +20,12 @@ case class BulkLoadIntoTable(
2020
// TODO:need resolved here?
2121
2222
}
23-
23+
*/
2424
case class LoadDataIntoTable(path: String,
2525
child: LogicalPlan,
26-
isLocal: Boolean) extends LogicalPlan {
26+
isLocal: Boolean) extends UnaryNode {
27+
28+
override def output = Nil
2729

2830
override def toString = s"LogicalPlan: LoadDataIntoTable(LOAD $path INTO $child)"
2931
}

0 commit comments

Comments
 (0)