quarks.execution

Interface Submitter<E,J extends Job>

Type Parameters:

E - the executable type

J - 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

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 to submit(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 submit

config - context information for the submission

Returns:

a future for the submitted executable