main.scala

object Main {
  def main(args: Array[String]) {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    
    clicks = env.readFile("myclicks.txt")

    result = clicks
      .map(new ClickTransformer)
      .keyBy(0)
      .window(EventTimeSessionWindows.withGap(Time.minutes(30L)))
      .reduce(new ClickReducer)
    
    result.writeAsText("output.txt")
  }
}