You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spot.apache.org by na...@apache.org on 2018/03/19 19:28:41 UTC
[32/42] incubator-spot git commit: style fixes argparse
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/SPOT-181_ODM
Commit: 51040a2c112f81ec99873b882c65bf19ba45e1fb
Parents: df86326
Author: tpltnt <tp...@dropcut.net>
Authored: Thu Jan 25 11:32:25 2018 +0100
Committer: tpltnt <tp...@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.