Class InternalExecuted
- java.lang.Object
-
- io.streamthoughts.azkarra.api.Executed
-
- io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
-
public class InternalExecuted extends Executed
-
-
Field Summary
-
Fields inherited from class io.streamthoughts.azkarra.api.Executed
config, description, factory, interceptors, name
-
-
Constructor Summary
Constructors Constructor Description InternalExecuted()
Creates a newInternalExecuted
instance.InternalExecuted(Executed executed)
Creates a newInternalExecuted
instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Conf
config()
String
description()
String
descriptionOrElseGet(String defaultValue)
Optional<Supplier<KafkaStreamsFactory>>
factory()
List<Supplier<StreamsLifecycleInterceptor>>
interceptors()
String
name()
String
nameOrElseGet(String defaultValue)
-
Methods inherited from class io.streamthoughts.azkarra.api.Executed
as, as, with, withConfig, withDescription, withInterceptor, withInterceptors, withKafkaStreamsFactory, withName
-
-
-
-
Constructor Detail
-
InternalExecuted
public InternalExecuted()
Creates a newInternalExecuted
instance.
-
InternalExecuted
public InternalExecuted(Executed executed)
Creates a newInternalExecuted
instance.- Parameters:
executed
- theExecuted
instance.
-
-
Method Detail
-
name
public String name()
-
description
public String description()
-
config
public Conf config()
-
interceptors
public List<Supplier<StreamsLifecycleInterceptor>> interceptors()
-
factory
public Optional<Supplier<KafkaStreamsFactory>> factory()
-
-