I have tried these formats for defining next job but they all result in
xception in thread "main" cascading.flow.planner.PlannerException: source taps are required
at cascading.flow.planner.FlowPlanner.verifyTaps(FlowPlanner.java:170)
at cascading.flow.planner.FlowPlanner.verifyAssembly(FlowPlanner.java:121)
at cascading.flow.local.planner.LocalPlanner.buildFlow(LocalPlanner.java:57)
at cascading.flow.FlowConnector.connect(FlowConnector.java:454)
class KcenterClustering(args: Args) extends Job(args){
override def next : Option[Job] = Some(new CalculateClusterNode(args, args("clusterSize").toInt , Array("9q8up7n")))
}
or
class KcenterClustering(args: Args) extends Job(args){
new CalculateClusterNode(args, args("clusterSize").toInt , Array("9q8up7n"))
}
CalculateClusterNode is also a scalding job
Any guidance is most welcome.