2 files changed, 6 insertions, 6 deletions
diff --git a/scalding/src/main/scala/sandcrawler/HBaseCountJob.scala b/scalding/src/main/scala/sandcrawler/HBaseCountJob.scala
index 53ce325..863c16f 100644
--- a/scalding/src/main/scala/sandcrawler/HBaseCountJob.scala
+++ b/scalding/src/main/scala/sandcrawler/HBaseCountJob.scala
@@ -24,9 +24,9 @@ class HBaseCountJob(args: Args, colSpec: String) extends JobBase(args) with HBas
 }
 
 object HBaseCountJob {
-  def getHBaseSource(hbase_table: String, zookeeper_hosts: String, colSpec: String) = HBaseBuilder.build(
-    hbase_table,      // HBase Table Name
-    zookeeper_hosts,  // HBase Zookeeper server (to get runtime config info; can be array?)
+  def getHBaseSource(hbaseTable: String, zookeeperHosts: String, colSpec: String) = HBaseBuilder.build(
+    hbaseTable,      // HBase Table Name
+    zookeeperHosts,  // HBase Zookeeper server (to get runtime config info; can be array?)
     List(colSpec),
     SourceMode.SCAN_ALL)
 }
diff --git a/scalding/src/main/scala/sandcrawler/HBaseRowCountJob.scala b/scalding/src/main/scala/sandcrawler/HBaseRowCountJob.scala
index 7f5c84a..334b7a6 100644
--- a/scalding/src/main/scala/sandcrawler/HBaseRowCountJob.scala
+++ b/scalding/src/main/scala/sandcrawler/HBaseRowCountJob.scala
@@ -23,10 +23,10 @@ class HBaseRowCountJob(args: Args) extends JobBase(args) with HBasePipeConversio
 object HBaseRowCountJob {
 
   // eg, "wbgrp-journal-extract-0-qa", "mtrcs-zk1.us.archive.org:2181"
-  def getHBaseSource(hbase_table: String, zookeeper_hosts: String) : HBaseSource = {
+  def getHBaseSource(hbaseTable: String, zookeeperHosts: String) : HBaseSource = {
     return HBaseBuilder.build(
-      hbase_table,
-      zookeeper_hosts,
+      hbaseTable,
+      zookeeperHosts,
       List("file:size"),
       SourceMode.SCAN_ALL)
   }