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 | |
| 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')
| -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() |