aboutsummaryrefslogtreecommitdiff
path: root/examples/src/main/scala/spark/examples/HBaseTest.scala
diff options
context:
space:
mode:
Diffstat (limited to 'examples/src/main/scala/spark/examples/HBaseTest.scala')
-rw-r--r--examples/src/main/scala/spark/examples/HBaseTest.scala6
1 files changed, 2 insertions, 4 deletions
diff --git a/examples/src/main/scala/spark/examples/HBaseTest.scala b/examples/src/main/scala/spark/examples/HBaseTest.scala
index 90ff64b483..37aedde302 100644
--- a/examples/src/main/scala/spark/examples/HBaseTest.scala
+++ b/examples/src/main/scala/spark/examples/HBaseTest.scala
@@ -2,7 +2,7 @@ package spark.examples
import spark._
import spark.rdd.NewHadoopRDD
-import org.apache.hadoop.hbase.{HBaseConfiguration, HTableDescriptor, HColumnDescriptor}
+import org.apache.hadoop.hbase.{HBaseConfiguration, HTableDescriptor}
import org.apache.hadoop.hbase.client.HBaseAdmin
import org.apache.hadoop.hbase.mapreduce.TableInputFormat
@@ -14,12 +14,10 @@ object HBaseTest {
val conf = HBaseConfiguration.create()
conf.set(TableInputFormat.INPUT_TABLE, args(1))
- // Initialize hBase tables if necessary
+ // Initialize hBase table if necessary
val admin = new HBaseAdmin(conf)
if(!admin.isTableAvailable(args(1))) {
- val colDesc = new HColumnDescriptor(args(2))
val tableDesc = new HTableDescriptor(args(1))
- tableDesc.addFamily(colDesc)
admin.createTable(tableDesc)
}