Skip to content
Snippets Groups Projects
Commit 7cff7e78 authored by Ethan Jewett's avatar Ethan Jewett
Browse files

Fix indents and mention other configuration options

parent 9290f164
No related branches found
No related tags found
No related merge requests found
...@@ -12,6 +12,9 @@ object HBaseTest { ...@@ -12,6 +12,9 @@ object HBaseTest {
System.getenv("SPARK_HOME"), Seq(System.getenv("SPARK_EXAMPLES_JAR"))) System.getenv("SPARK_HOME"), Seq(System.getenv("SPARK_EXAMPLES_JAR")))
val conf = HBaseConfiguration.create() val conf = HBaseConfiguration.create()
// Other options for configuring scan behavior are available. More information available at
// http://hbase.apache.org/apidocs/org/apache/hadoop/hbase/mapreduce/TableInputFormat.html
conf.set(TableInputFormat.INPUT_TABLE, args(1)) conf.set(TableInputFormat.INPUT_TABLE, args(1))
// Initialize hBase table if necessary // Initialize hBase table if necessary
...@@ -22,8 +25,8 @@ object HBaseTest { ...@@ -22,8 +25,8 @@ object HBaseTest {
} }
val hBaseRDD = new NewHadoopRDD(sc, classOf[TableInputFormat], val hBaseRDD = new NewHadoopRDD(sc, classOf[TableInputFormat],
classOf[org.apache.hadoop.hbase.io.ImmutableBytesWritable], classOf[org.apache.hadoop.hbase.io.ImmutableBytesWritable],
classOf[org.apache.hadoop.hbase.client.Result], conf) classOf[org.apache.hadoop.hbase.client.Result], conf)
hBaseRDD.count() hBaseRDD.count()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment