diff options
| author | Bryan Newbold <bnewbold@archive.org> | 2018-08-22 03:02:06 +0000 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@archive.org> | 2018-08-21 21:34:28 -0700 |
| commit | 9557323addb8ab0b7f84dc404e8ef3d76243f13f (patch) | |
| tree | 56ecd3336a727aac1eed411a73e7b3417730f0b1 | |
| parent | bd9c6564a07eb1b5d9c6a25942a198dc3800281b (diff) | |
| download | sandcrawler-9557323addb8ab0b7f84dc404e8ef3d76243f13f.tar.gz sandcrawler-9557323addb8ab0b7f84dc404e8ef3d76243f13f.zip | |
fixes to please keys-missing-col
| -rwxr-xr-x | please | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -226,7 +226,7 @@ def run_keysmissingcol(args): args.column.replace(":", "_")) cmd = """hadoop jar \ scalding/target/scala-2.11/sandcrawler-assembly-0.2.0-SNAPSHOT.jar \ - com.twitter.scalding.Tool sandcrawler.MissingColDumpJob \ + com.twitter.scalding.Tool sandcrawler.MissingColumnDumpJob \ --hdfs \ --app.conf.path scalding/ia_cluster.conf \ --hbase-table wbgrp-journal-extract-0-{env} \ @@ -289,7 +289,7 @@ def main(): help="column name to use in count") sub_keysmissingcol = subparsers.add_parser('keys-missing-col') - sub_keysmissingcol.set_defaults(func=run_matchcrossref) + sub_keysmissingcol.set_defaults(func=run_keysmissingcol) sub_keysmissingcol.add_argument('column', help="column to SCAN for missing keys") |