diff options
author | Ethan Jewett <esjewett@gmail.com> | 2013-05-04 14:56:55 -0500 |
---|---|---|
committer | Ethan Jewett <esjewett@gmail.com> | 2013-05-04 14:56:55 -0500 |
commit | 7cff7e789723b646d1692fc71ef99f89a862bdc6 (patch) | |
tree | 6e84cef7880d6ef534cf4ba5e1479f8300721357 /examples/src | |
parent | 9290f16430f92c66d4ec3b1ec76e491ae7cf26dc (diff) | |
download | spark-7cff7e789723b646d1692fc71ef99f89a862bdc6.tar.gz spark-7cff7e789723b646d1692fc71ef99f89a862bdc6.tar.bz2 spark-7cff7e789723b646d1692fc71ef99f89a862bdc6.zip |
Fix indents and mention other configuration options
Diffstat (limited to 'examples/src')
-rw-r--r-- | examples/src/main/scala/spark/examples/HBaseTest.scala | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/examples/src/main/scala/spark/examples/HBaseTest.scala b/examples/src/main/scala/spark/examples/HBaseTest.scala index 37aedde302..d94b25828d 100644 --- a/examples/src/main/scala/spark/examples/HBaseTest.scala +++ b/examples/src/main/scala/spark/examples/HBaseTest.scala @@ -12,6 +12,9 @@ object HBaseTest { System.getenv("SPARK_HOME"), Seq(System.getenv("SPARK_EXAMPLES_JAR"))) 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)) // Initialize hBase table if necessary @@ -22,8 +25,8 @@ object HBaseTest { } val hBaseRDD = new NewHadoopRDD(sc, classOf[TableInputFormat], - classOf[org.apache.hadoop.hbase.io.ImmutableBytesWritable], - classOf[org.apache.hadoop.hbase.client.Result], conf) + classOf[org.apache.hadoop.hbase.io.ImmutableBytesWritable], + classOf[org.apache.hadoop.hbase.client.Result], conf) hBaseRDD.count() |