Package io.streamthoughts.azkarra.api
Class Executed
- java.lang.Object
-
- io.streamthoughts.azkarra.api.Executed
-
- Direct Known Subclasses:
InternalExecuted
public class Executed extends Object
Executed class is used to describe aTopology
instance to be executed.
-
-
Field Summary
Fields Modifier and Type Field Description protected Conf
config
protected String
description
protected Supplier<KafkaStreamsFactory>
factory
protected List<Supplier<StreamsLifecycleInterceptor>>
interceptors
protected String
name
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Executed
as(String name)
Static helper that can be used to creates a newExecuted
instance with the specified streams name.static 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
with(Conf conf)
Static helper that can be used to creates a newExecuted
instance with the specified streams name and configuration.Executed
withConfig(Conf config)
Returns a newExecuted
with the specified config.Executed
withDescription(String description)
Returns a newExecuted
with the specified description.Executed
withInterceptor(Supplier<StreamsLifecycleInterceptor> interceptor)
Returns a newExecuted
with the specified interceptor.Executed
withInterceptors(List<Supplier<StreamsLifecycleInterceptor>> interceptors)
Returns a newExecuted
with the specified interceptors.Executed
withKafkaStreamsFactory(Supplier<KafkaStreamsFactory> factory)
Returns a newExecuted
with the specifiedKafkaStreams
factory.Executed
withName(String name)
Returns a newExecuted
with the specified name.
-
-
-
Field Detail
-
name
protected final String name
-
description
protected final String description
-
config
protected final Conf config
-
factory
protected final Supplier<KafkaStreamsFactory> factory
-
interceptors
protected final List<Supplier<StreamsLifecycleInterceptor>> interceptors
-
-
Method Detail
-
as
public static Executed as(String name)
Static helper that can be used to creates a newExecuted
instance with the specified streams name.- Parameters:
name
- the name of the streams application.- Returns:
- a new
StreamsExecutionEnvironment
instance.
-
as
public static Executed as(String name, String description)
Static helper that can be used to creates a newExecuted
instance with the specified streams name and description.- Parameters:
name
- the name of the streams application.description
- the description of the streams application.- Returns:
- a new
StreamsExecutionEnvironment
instance.
-
with
public static Executed with(Conf conf)
Static helper that can be used to creates a newExecuted
instance with the specified streams name and configuration.- Parameters:
conf
- the configuration.- Returns:
- a new
StreamsExecutionEnvironment
instance.
-
withName
public Executed withName(String name)
Returns a newExecuted
with the specified name.- Parameters:
name
- the name of the streams topology.- Returns:
- a new
Executed
.
-
withDescription
public Executed withDescription(String description)
Returns a newExecuted
with the specified description.- Parameters:
description
- the description of the streams topology.- Returns:
- a new
Executed
.
-
withConfig
public Executed withConfig(Conf config)
Returns a newExecuted
with the specified config.- Parameters:
config
- the config of the streams topology.- Returns:
- a new
Executed
.
-
withInterceptor
public Executed withInterceptor(Supplier<StreamsLifecycleInterceptor> interceptor)
Returns a newExecuted
with the specified interceptor.- Parameters:
interceptor
- the interceptor to add to the streams topology.- Returns:
- a new
Executed
.
-
withInterceptors
public Executed withInterceptors(List<Supplier<StreamsLifecycleInterceptor>> interceptors)
Returns a newExecuted
with the specified interceptors.- Parameters:
interceptors
- the interceptors to add to the streams topology.- Returns:
- a new
Executed
.
-
withKafkaStreamsFactory
public Executed withKafkaStreamsFactory(Supplier<KafkaStreamsFactory> factory)
Returns a newExecuted
with the specifiedKafkaStreams
factory.- Parameters:
factory
- theKafkaStreams
factory to be used.- Returns:
- a new
Executed
.
-
-