diff options
author | Ethan Jewett <esjewett@gmail.com> | 2013-05-07 11:43:06 -0500 |
---|---|---|
committer | Ethan Jewett <esjewett@gmail.com> | 2013-05-07 11:43:06 -0500 |
commit | a3d5f922109caa878f8350fe0634514b8af55cbc (patch) | |
tree | 18f6ffbfb6d7d55df3cd09109f5a8539b8d3236b | |
parent | 7cff7e789723b646d1692fc71ef99f89a862bdc6 (diff) | |
download | spark-a3d5f922109caa878f8350fe0634514b8af55cbc.tar.gz spark-a3d5f922109caa878f8350fe0634514b8af55cbc.tar.bz2 spark-a3d5f922109caa878f8350fe0634514b8af55cbc.zip |
Switch to using SparkContext method to create RDD
-rw-r--r-- | examples/src/main/scala/spark/examples/HBaseTest.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/examples/src/main/scala/spark/examples/HBaseTest.scala b/examples/src/main/scala/spark/examples/HBaseTest.scala index d94b25828d..9bad876860 100644 --- a/examples/src/main/scala/spark/examples/HBaseTest.scala +++ b/examples/src/main/scala/spark/examples/HBaseTest.scala @@ -24,9 +24,9 @@ object HBaseTest { admin.createTable(tableDesc) } - val hBaseRDD = new NewHadoopRDD(sc, classOf[TableInputFormat], + val hBaseRDD = sc.newAPIHadoopRDD(conf, classOf[TableInputFormat], classOf[org.apache.hadoop.hbase.io.ImmutableBytesWritable], - classOf[org.apache.hadoop.hbase.client.Result], conf) + classOf[org.apache.hadoop.hbase.client.Result]) hBaseRDD.count() |