diff --git a/8.1 max-temperatures.py.py b/8.1 max-temperatures.py.py index 5150d0a..97d5076 100644 --- a/8.1 max-temperatures.py.py +++ b/8.1 max-temperatures.py.py @@ -1,4 +1,5 @@ from pyspark import SparkConf, SparkContext +import sparkSession conf = SparkConf().setMaster("local").setAppName("MaxTemperatures") sc = SparkContext(conf = conf) @@ -17,6 +18,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(); +lines=my.lines.collect() for result in results: print(result[0] + "\t{:.2f}F".format(result[1]))