Package io.streamthoughts.azkarra.runtime

Class AbstractTopologyStreamsExecution<E extends StreamsExecutionEnvironment<E>>

java.lang.Object

io.streamthoughts.azkarra.runtime.AbstractTopologyStreamsExecution<E>

All Implemented Interfaces:

StreamsTopologyExecution, Callable<Optional<ApplicationId>>

Direct Known Subclasses:

LocalStreamsExecution

public abstract class AbstractTopologyStreamsExecution<E extends StreamsExecutionEnvironment<E>>
extends Object
implements StreamsTopologyExecution

Field Summary

Fields

Modifier and Type	Field	Description
protected E	environment
protected InternalExecuted	executed
protected StreamsTopologyMeta	meta

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractTopologyStreamsExecution(E environment, StreamsTopologyMeta meta, Executed executed)	Creates a new AbstractTopologyStreamsExecution instance.

Method Summary

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, start

Field Detail

environment

protected E extends StreamsExecutionEnvironment<E> environment

meta

protected StreamsTopologyMeta meta

executed

protected InternalExecuted executed

Constructor Detail

AbstractTopologyStreamsExecution

protected AbstractTopologyStreamsExecution(E environment,
                                           StreamsTopologyMeta meta,
                                           Executed executed)

Creates a new AbstractTopologyStreamsExecution instance.

Parameters:

environment - the execution environment.

meta - the StreamsTopologyMeta meta-information to be executed.

executed - the execution options.