style fixes argparse
Project: http://git-wip-us.apache.org/repos/asf/incubator-spot/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spot/commit/51040a2c Tree: http://git-wip-us.apache.org/repos/asf/incubator-spot/tree/51040a2c Diff: http://git-wip-us.apache.org/repos/asf/incubator-spot/diff/51040a2c Branch: refs/heads/master Commit: 51040a2c112f81ec99873b882c65bf19ba45e1fb Parents: df86326 Author: tpltnt <tpltnt.git...@dropcut.net> Authored: Thu Jan 25 11:32:25 2018 +0100 Committer: tpltnt <tpltnt.git...@dropcut.net> Committed: Thu Jan 25 11:33:03 2018 +0100 ---------------------------------------------------------------------- spot-ingest/pipelines/proxy/bluecoat.py | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spot/blob/51040a2c/spot-ingest/pipelines/proxy/bluecoat.py ---------------------------------------------------------------------- diff --git a/spot-ingest/pipelines/proxy/bluecoat.py b/spot-ingest/pipelines/proxy/bluecoat.py index 5e36a4e..898ff2e 100644 --- a/spot-ingest/pipelines/proxy/bluecoat.py +++ b/spot-ingest/pipelines/proxy/bluecoat.py @@ -68,12 +68,18 @@ def main(): """ # input Parameters parser = argparse.ArgumentParser(description="Bluecoat Parser") - parser.add_argument('-zk','--zookeeper',dest='zk',required=True,help='Zookeeper IP and port (i.e. 10.0.0.1:2181)',metavar='') - parser.add_argument('-t','--topic',dest='topic',required=True,help='Topic to listen for Spark Streaming',metavar='') - parser.add_argument('-db','--database',dest='db',required=True,help='Hive database whete the data will be ingested',metavar='') - parser.add_argument('-dt','--db-table',dest='db_table',required=True,help='Hive table whete the data will be ingested',metavar='') - parser.add_argument('-w','--num_of_workers',dest='num_of_workers',required=True,help='Num of workers for Parallelism in Data Processing',metavar='') - parser.add_argument('-bs','--batch-size',dest='batch_size',required=True,help='Batch Size (Milliseconds)',metavar='') + parser.add_argument('-zk', '--zookeeper', dest='zk', required=True, + help='Zookeeper IP and port (i.e. 10.0.0.1:2181)', metavar='') + parser.add_argument('-t', '--topic', dest='topic', required=True, + help='Topic to listen for Spark Streaming', metavar='') + parser.add_argument('-db', '--database', dest='db', required=True, + help='Hive database whete the data will be ingested', metavar='') + parser.add_argument('-dt', '--db-table', dest='db_table', required=True, + help='Hive table whete the data will be ingested', metavar='') + parser.add_argument('-w', '--num_of_workers', dest='num_of_workers', required=True, + help='Num of workers for Parallelism in Data Processing', metavar='') + parser.add_argument('-bs', '--batch-size', dest='batch_size', required=True, + help='Batch Size (Milliseconds)', metavar='') args = parser.parse_args() # start collector based on data source type.