Class LocalStreamsExecution
- java.lang.Object
-
- io.streamthoughts.azkarra.runtime.AbstractTopologyStreamsExecution<LocalStreamsExecutionEnvironment>
-
- io.streamthoughts.azkarra.runtime.env.LocalStreamsExecution
-
- All Implemented Interfaces:
StreamsTopologyExecution
,Callable<Optional<ApplicationId>>
public class LocalStreamsExecution extends AbstractTopologyStreamsExecution<LocalStreamsExecutionEnvironment>
-
-
Field Summary
-
Fields inherited from class io.streamthoughts.azkarra.runtime.AbstractTopologyStreamsExecution
environment, executed, meta
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Optional<ApplicationId>
start()
Starts the streams-topology encapsulated by this object.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.streamthoughts.azkarra.api.StreamsTopologyExecution
call
-
-
-
-
Method Detail
-
start
public Optional<ApplicationId> start()
Starts the streams-topology encapsulated by this object.- Returns:
- the
ApplicationId
.
-
-