Uses of Class
io.streamthoughts.azkarra.api.Executed
-
-
Uses of Executed in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return Executed Modifier and Type Method Description static Executed
Executed. as(String name)
Static helper that can be used to creates a newExecuted
instance with the specified streams name.static Executed
Executed. as(String name, String description)
Static helper that can be used to creates a newExecuted
instance with the specified streams name and description.static Executed
Executed. with(Conf conf)
Static helper that can be used to creates a newExecuted
instance with the specified streams name and configuration.Executed
Executed. withConfig(Conf config)
Returns a newExecuted
with the specified config.Executed
Executed. withDescription(String description)
Returns a newExecuted
with the specified description.Executed
Executed. withInterceptor(Supplier<StreamsLifecycleInterceptor> interceptor)
Returns a newExecuted
with the specified interceptor.Executed
Executed. withInterceptors(List<Supplier<StreamsLifecycleInterceptor>> interceptors)
Returns a newExecuted
with the specified interceptors.Executed
Executed. withName(String name)
Returns a newExecuted
with the specified name.Methods in io.streamthoughts.azkarra.api with parameters of type Executed Modifier and Type Method Description ApplicationId
AzkarraContext. addTopology(Class<? extends TopologyProvider> type, Executed executed)
Adds a topology to the default environment of this context.ApplicationId
AzkarraContext. addTopology(Class<? extends TopologyProvider> type, String environment, Executed executed)
Adds a topology to a specified environment.ApplicationId
AzkarraContext. addTopology(String type, Executed executed)
Adds a topology to the default environment of this context.ApplicationId
AzkarraContext. addTopology(String type, String environment, Executed executed)
Adds a topology to a specified environment.ApplicationId
AzkarraContext. addTopology(String type, String version, String environment, Executed executed)
Adds a topology to a specified environment.ApplicationId
StreamsExecutionEnvironment. addTopology(Supplier<TopologyProvider> provider, Executed executed)
Add a newTopologyProvider
instance to thisStreamsExecutionEnvironment
to be started.ApplicationId
AzkarraStreamsService. startStreamsTopology(String topologyType, String topologyVersion, String env, Executed executed)
Creates and starts a new streams job for the specified topology into the specified environment.Constructors in io.streamthoughts.azkarra.api with parameters of type Executed Constructor Description Executed(Executed executed)
-
Uses of Executed in io.streamthoughts.azkarra.runtime.context
Methods in io.streamthoughts.azkarra.runtime.context with parameters of type Executed Modifier and Type Method Description ApplicationId
DefaultAzkarraContext. addTopology(Class<? extends TopologyProvider> type, Executed executed)
Adds a topology to the default environment of this context.ApplicationId
DefaultAzkarraContext. addTopology(Class<? extends TopologyProvider> type, String envName, Executed executed)
Adds a topology to a specified environment.ApplicationId
DefaultAzkarraContext. addTopology(String type, Executed executed)
Adds a topology to the default environment of this context.ApplicationId
DefaultAzkarraContext. addTopology(String type, String environment, Executed executed)
Adds a topology to a specified environment.ApplicationId
DefaultAzkarraContext. addTopology(String type, String version, String environment, Executed executed)
Adds a topology to a specified environment. -
Uses of Executed in io.streamthoughts.azkarra.runtime.env
Methods in io.streamthoughts.azkarra.runtime.env with parameters of type Executed Modifier and Type Method Description ApplicationId
DefaultStreamsExecutionEnvironment. addTopology(Supplier<TopologyProvider> provider, Executed executed)
Add a newTopologyProvider
instance to thisStreamsExecutionEnvironment
to be started. -
Uses of Executed in io.streamthoughts.azkarra.runtime.env.internal
Methods in io.streamthoughts.azkarra.runtime.env.internal with parameters of type Executed Modifier and Type Method Description TopologyContainer
TopologyContainerFactory. make(Supplier<TopologyProvider> providerSupplier, Executed executed)
Makes aTopology
instance using the specifiedTopologyDescriptor
. -
Uses of Executed in io.streamthoughts.azkarra.runtime.service
Methods in io.streamthoughts.azkarra.runtime.service with parameters of type Executed Modifier and Type Method Description ApplicationId
LocalAzkarraStreamsService. startStreamsTopology(String topologyType, String topologyVersion, String env, Executed executed)
Creates and starts a new streams job for the specified topology into the specified environment. -
Uses of Executed in io.streamthoughts.azkarra.runtime.streams.topology
Subclasses of Executed in io.streamthoughts.azkarra.runtime.streams.topology Modifier and Type Class Description class
InternalExecuted
Constructors in io.streamthoughts.azkarra.runtime.streams.topology with parameters of type Executed Constructor Description InternalExecuted(Executed executed)
Creates a newInternalExecuted
instance.
-