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. withKafkaStreamsFactory(Supplier<KafkaStreamsFactory> factory)
Returns a newExecuted
with the specifiedKafkaStreams
factory.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 Optional<ApplicationId>
AzkarraContext. addTopology(Class<? extends TopologyProvider> type, Executed executed)
Adds a topology to the default environment of this context.Optional<ApplicationId>
AzkarraContext. addTopology(Class<? extends TopologyProvider> type, String environment, Executed executed)
Adds a topology to a specified environment.Optional<ApplicationId>
AzkarraContext. addTopology(String type, Executed executed)
Adds a topology to the default environment of this context.Optional<ApplicationId>
AzkarraContext. addTopology(String type, String environment, Executed executed)
Adds a topology to a specified environment.Optional<ApplicationId>
AzkarraContext. addTopology(String type, String version, String environment, Executed executed)
Adds a topology to a specified environment.StreamsTopologyExecution
StreamsExecutionEnvironment. newTopologyExecution(StreamsTopologyMeta meta, Executed executed)
Creates a newStreamsTopologyExecution
to be applied on thisStreamsExecutionEnvironment
.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
Constructors in io.streamthoughts.azkarra.runtime with parameters of type Executed Constructor Description AbstractTopologyStreamsExecution(E environment, StreamsTopologyMeta meta, Executed executed)
Creates a newAbstractTopologyStreamsExecution
instance. -
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 Optional<ApplicationId>
DefaultAzkarraContext. addTopology(Class<? extends TopologyProvider> type, Executed executed)
Adds a topology to the default environment of this context.Optional<ApplicationId>
DefaultAzkarraContext. addTopology(Class<? extends TopologyProvider> type, String environment, Executed executed)
Adds a topology to a specified environment.Optional<ApplicationId>
DefaultAzkarraContext. addTopology(String type, Executed executed)
Adds a topology to the default environment of this context.Optional<ApplicationId>
DefaultAzkarraContext. addTopology(String type, String environment, Executed executed)
Adds a topology to a specified environment.Optional<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 Optional<ApplicationId>
LocalStreamsExecutionEnvironment. addTopology(Supplier<TopologyProvider> supplier, Executed executed)
Adds a newTopologyProvider
instance to thisStreamsExecutionEnvironment
.StreamsTopologyExecution
LocalStreamsExecutionEnvironment. newTopologyExecution(StreamsTopologyMeta meta, Executed executed)
Creates a newStreamsTopologyExecution
to be applied on thisStreamsExecutionEnvironment
.LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. registerTopology(Supplier<TopologyProvider> supplier, Executed executed)
Registers a newTopologyProvider
instance to thisStreamsExecutionEnvironment
.LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. registerTopology(org.apache.kafka.streams.Topology topology, Version version, Executed executed)
Registers a newTopologyProvider
instance to thisStreamsExecutionEnvironment
. -
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.
-