quarks.execution
Interface Submitter<E,J extends Job>
-
- Type Parameters:
E
- the executable typeJ
- the submitted executable's future
- All Known Subinterfaces:
- DirectSubmitter<E,J>
- All Known Implementing Classes:
- DevelopmentProvider, DirectProvider
public interface Submitter<E,J extends Job>
An interface for submission of an executable.The class implementing this interface is responsible for the semantics of this operation. e.g., an direct topology provider would run the topology as threads in the current jvm.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description java.util.concurrent.Future<J>
submit(E executable, com.google.gson.JsonObject config)
Submit an executable.java.util.concurrent.Future<J>
submit(E executable)
Submit an executable.
-
-
-
Method Detail
-
submit
java.util.concurrent.Future<J> submit(E executable)
Submit an executable. No configuration options are specified, this is equivalent tosubmit(executable, new JsonObject())
.- Parameters:
executable
- executable to submit- Returns:
- a future for the submitted executable
-
submit
java.util.concurrent.Future<J> submit(E executable, com.google.gson.JsonObject config)
Submit an executable.- Parameters:
executable
- executable to submitconfig
- context information for the submission- Returns:
- a future for the submitted executable
-
-