Showing
1 changed file
with
2 additions
and
2 deletions
| ... | @@ -21,13 +21,13 @@ public class calForwardTimeDelta { | ... | @@ -21,13 +21,13 @@ public class calForwardTimeDelta { |
| 21 | .appName("Detecting Fraud Clicks") | 21 | .appName("Detecting Fraud Clicks") |
| 22 | .getOrCreate(); | 22 | .getOrCreate(); |
| 23 | 23 | ||
| 24 | - //run methods here | 24 | + //run methods hereu |
| 25 | calcDelta(spark); | 25 | calcDelta(spark); |
| 26 | } | 26 | } |
| 27 | 27 | ||
| 28 | private static void calcDelta(SparkSession spark){ | 28 | private static void calcDelta(SparkSession spark){ |
| 29 | // put the path the file you gonna deal with being placed | 29 | // put the path the file you gonna deal with being placed |
| 30 | - String filepath = "/home/chris/.kaggle/competitions/talkingdata-adtracking-fraud-detection/mnt/ssd/kaggle-talkingdata2/competition_files/train_sample.csv"; | 30 | + String filepath = "train_sample.csv"; |
| 31 | 31 | ||
| 32 | // create Dataset from files | 32 | // create Dataset from files |
| 33 | Dataset<Row> logDF = spark.read() | 33 | Dataset<Row> logDF = spark.read() | ... | ... |
-
Please register or login to post a comment