import com.hydra.core.Job;
import com.hydra.core.Task;
import com.hydra.core.TaskContext;
public class MyDistributedJob implements Job {
@Override
public Task createTask(TaskContext context) {
return new MyDistributedTask();
}
@Override
public void completionCallback(TaskContext context) {
}
}
public class MyDistributedTask implements Task {
@Override
public void run(TaskContext context) {
}
}
