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 /examples | |
| parent | 7cff7e789723b646d1692fc71ef99f89a862bdc6 (diff) | |
| download | spark-a3d5f922109caa878f8350fe0634514b8af55cbc.tar.gz spark-a3d5f922109caa878f8350fe0634514b8af55cbc.tar.bz2 spark-a3d5f922109caa878f8350fe0634514b8af55cbc.zip | |
Switch to using SparkContext method to create RDD
Diffstat (limited to 'examples')
| -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() |