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)
}
}