Showing
1 changed file
with
2 additions
and
1 deletions
| ... | @@ -28,9 +28,10 @@ public class Aggregation { | ... | @@ -28,9 +28,10 @@ public class Aggregation { |
| 28 | dataset = agg.clickTimeDelta(dataset); | 28 | dataset = agg.clickTimeDelta(dataset); |
| 29 | dataset = agg.countClickInTenMinutes(dataset); | 29 | dataset = agg.countClickInTenMinutes(dataset); |
| 30 | 30 | ||
| 31 | - //test | 31 | + // test |
| 32 | dataset.where("ip == '5348' and app == '19'").show(10); | 32 | dataset.where("ip == '5348' and app == '19'").show(10); |
| 33 | 33 | ||
| 34 | + // Save to scv | ||
| 34 | Utill.saveCSVDataSet(dataset, "./agg_data"); | 35 | Utill.saveCSVDataSet(dataset, "./agg_data"); |
| 35 | } | 36 | } |
| 36 | 37 | ... | ... |
-
Please register or login to post a comment