diff options
author | Ethan Jewett <esjewett@gmail.com> | 2013-05-04 12:39:14 -0500 |
---|---|---|
committer | Ethan Jewett <esjewett@gmail.com> | 2013-05-04 12:39:14 -0500 |
commit | 9290f16430f92c66d4ec3b1ec76e491ae7cf26dc (patch) | |
tree | 88a29ecd1b4a5dc9d1df34997176f4c4ee94a682 /examples/src | |
parent | 02e8cfa61792f296555c7ed16613a91d895181a1 (diff) | |
download | spark-9290f16430f92c66d4ec3b1ec76e491ae7cf26dc.tar.gz spark-9290f16430f92c66d4ec3b1ec76e491ae7cf26dc.tar.bz2 spark-9290f16430f92c66d4ec3b1ec76e491ae7cf26dc.zip |
Remove unnecessary column family config
Diffstat (limited to 'examples/src')
-rw-r--r-- | examples/src/main/scala/spark/examples/HBaseTest.scala | 6 |
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) } |