def main()

in spark-application/src/main/scala/ValueZones.scala [38:65]


  def main(args: Array[String]) {

    // check arguments
    if (args.length != 5)
      throw new IllegalArgumentException(
        "Parameters : "+
          "<tripDataBucket>"+
          "<yearsToProcess>"+
          "<zoneLookup>"+
          "<targetBucket>"+
          "<dbName>"
      )
    logger.setLevel(Level.INFO)
    try {

      runJob(yellow=buildSourcePath(args(0), "yellow", args(1)),
        green=buildSourcePath(args(0), "green", args(1)),
        zones = args(2),
        target = args(3),
        dbName = args(4)
      )
      session.stop()
    } catch {
      case ex: Exception =>
        logger.error(ex.getMessage)
        logger.error(ex.getStackTrace.toString)
    }
  }