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:40 UTC
[31/42] incubator-spot git commit: fixed identation
fixed identation
Project: http://git-wip-us.apache.org/repos/asf/incubator-spot/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spot/commit/df86326b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spot/tree/df86326b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spot/diff/df86326b
Branch: refs/heads/SPOT-181_ODM
Commit: df86326bf991a4f49c57e8aeeb4af0d8b059b21b
Parents: a99404b
Author: tpltnt <tp...@dropcut.net>
Authored: Thu Jan 25 11:30:12 2018 +0100
Committer: tpltnt <tp...@dropcut.net>
Committed: Thu Jan 25 11:30:12 2018 +0100
----------------------------------------------------------------------
spot-ingest/pipelines/proxy/bluecoat.py | 64 ++++++++++++++--------------
1 file changed, 32 insertions(+), 32 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spot/blob/df86326b/spot-ingest/pipelines/proxy/bluecoat.py
----------------------------------------------------------------------
diff --git a/spot-ingest/pipelines/proxy/bluecoat.py b/spot-ingest/pipelines/proxy/bluecoat.py
index 1fe02a2..5e36a4e 100644
--- a/spot-ingest/pipelines/proxy/bluecoat.py
+++ b/spot-ingest/pipelines/proxy/bluecoat.py
@@ -28,38 +28,38 @@ from pyspark.sql.types import *
rex_date = re.compile("\d{4}-\d{2}-\d{2}")
proxy_schema = StructType([
- StructField("p_date", StringType(), True),
- StructField("p_time", StringType(), True),
- StructField("clientip", StringType(), True),
- StructField("host", StringType(), True),
- StructField("reqmethod", StringType(), True),
- StructField("useragent", StringType(), True),
- StructField("resconttype", StringType(), True),
- StructField("duration", IntegerType(), True),
- StructField("username", StringType(), True),
- StructField("authgroup", StringType(), True),
- StructField("exceptionid", StringType(), True),
- StructField("filterresult", StringType(), True),
- StructField("webcat", StringType(), True),
- StructField("referer", StringType(), True),
- StructField("respcode", StringType(), True),
- StructField("action", StringType(), True),
- StructField("urischeme", StringType(), True),
- StructField("uriport", StringType(), True),
- StructField("uripath", StringType(), True),
- StructField("uriquery", StringType(), True),
- StructField("uriextension", StringType(), True),
- StructField("serverip", StringType(), True),
- StructField("scbytes", IntegerType(), True),
- StructField("csbytes", IntegerType(), True),
- StructField("virusid", StringType(), True),
- StructField("bcappname", StringType(), True),
- StructField("bcappoper", StringType(), True),
- StructField("fulluri", StringType(), True),
- StructField("y", StringType(), True),
- StructField("m", StringType(), True),
- StructField("d", StringType(), True),
- StructField("h", StringType(), True)])
+ StructField("p_date", StringType(), True),
+ StructField("p_time", StringType(), True),
+ StructField("clientip", StringType(), True),
+ StructField("host", StringType(), True),
+ StructField("reqmethod", StringType(), True),
+ StructField("useragent", StringType(), True),
+ StructField("resconttype", StringType(), True),
+ StructField("duration", IntegerType(), True),
+ StructField("username", StringType(), True),
+ StructField("authgroup", StringType(), True),
+ StructField("exceptionid", StringType(), True),
+ StructField("filterresult", StringType(), True),
+ StructField("webcat", StringType(), True),
+ StructField("referer", StringType(), True),
+ StructField("respcode", StringType(), True),
+ StructField("action", StringType(), True),
+ StructField("urischeme", StringType(), True),
+ StructField("uriport", StringType(), True),
+ StructField("uripath", StringType(), True),
+ StructField("uriquery", StringType(), True),
+ StructField("uriextension", StringType(), True),
+ StructField("serverip", StringType(), True),
+ StructField("scbytes", IntegerType(), True),
+ StructField("csbytes", IntegerType(), True),
+ StructField("virusid", StringType(), True),
+ StructField("bcappname", StringType(), True),
+ StructField("bcappoper", StringType(), True),
+ StructField("fulluri", StringType(), True),
+ StructField("y", StringType(), True),
+ StructField("m", StringType(), True),
+ StructField("d", StringType(), True),
+ StructField("h", StringType(), True)])
def main():
"""