Update miniprojectbda_review1.py
Browse files
miniprojectbda_review1.py
CHANGED
|
@@ -35,7 +35,7 @@ from datetime import datetime
|
|
| 35 |
|
| 36 |
spark = SparkSession.builder.appName("EnergyAnomalyDetection").getOrCreate()
|
| 37 |
|
| 38 |
-
train = spark.read.csv(
|
| 39 |
|
| 40 |
train.show()
|
| 41 |
|
|
|
|
| 35 |
|
| 36 |
spark = SparkSession.builder.appName("EnergyAnomalyDetection").getOrCreate()
|
| 37 |
|
| 38 |
+
train = spark.read.csv("train.csv", header=True, inferSchema=True)
|
| 39 |
|
| 40 |
train.show()
|
| 41 |
|