From 06b463d669435c4422f57902eca7f25cbc2b546e Mon Sep 17 00:00:00 2001 From: faceitvader <72166452+faceitvader@users.noreply.github.com> Date: Thu, 1 Oct 2020 01:47:14 +0530 Subject: [PATCH 1/2] Update 8.1 max-temperatures.py.py --- 8.1 max-temperatures.py.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/8.1 max-temperatures.py.py b/8.1 max-temperatures.py.py index 5150d0a..0f67f0b 100644 --- a/8.1 max-temperatures.py.py +++ b/8.1 max-temperatures.py.py @@ -25,3 +25,5 @@ def parseLine(line): results = maxTemps.collect(); resuls.collect() +stationTemps1 = maxTemps1.map(lambda x: (x[01], x[21])) +maxTemps2 = stationTemp2s.reduceByKey(lambda x, y: max(x,y)) From 437f025d12850a8f9d3c426f20a7630e6c95639c Mon Sep 17 00:00:00 2001 From: faceitvader <72166452+faceitvader@users.noreply.github.com> Date: Thu, 1 Oct 2020 01:48:37 +0530 Subject: [PATCH 2/2] Update 8.1 max-temperatures.py.py --- 8.1 max-temperatures.py.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/8.1 max-temperatures.py.py b/8.1 max-temperatures.py.py index 0f67f0b..96f581c 100644 --- a/8.1 max-temperatures.py.py +++ b/8.1 max-temperatures.py.py @@ -17,7 +17,7 @@ def parseLine(line): stationTemps = maxTemps.map(lambda x: (x[0], x[2])) maxTemps = stationTemps.reduceByKey(lambda x, y: max(x,y)) results = maxTemps.collect(); - +print("hello") for result in results: print(result[0] + "\t{:.2f}F".format(result[1])) stationTemps = maxTemps.flatMap(lambda x: (x[1], x[2]))