import org.scallop.core.annotations.ScallopMaster;
@ScallopMaster
public class Master {
}
import org.scallop.core.annotations.ScallopWorker;
@ScallopWorker
public class Worker {
}
public class Task {
}
public class Message {
}
import org.scallop.core.annotations.ScallopScheduler;
import org.scallop.core.ScallopContext;
@ScallopScheduler
public class Scheduler {
private ScallopContext context;
public Scheduler(ScallopContext context) {
this.context = context;
}
}
import org.scallop.core.annotations.ScallopExecutor;
import org.scallop.core.ScallopContext;
@ScallopExecutor
public class Executor {
private ScallopContext context;
public Executor(ScallopContext context) {
this.context = context;
}
}
import org.scallop.core.ScallopConfiguration;
public class Configuration implements ScallopConfiguration {
@Override
public int getMasterInstances() {
}
@Override
public int getWorkerInstances() {
}
}
import org.scallop.core.Scallop;
public class Main {
public static void main(String[] args) {
Configuration config = new Configuration();
Scallop scallop = new Scallop(config);
scallop.start();
}
}
