Package io.streamthoughts.azkarra.runtime.streams.topology

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, interceptors, name

Constructor Summary

Constructors

Constructor	Description
InternalExecuted()	Creates a new InternalExecuted instance.
InternalExecuted(Executed executed)	Creates a new InternalExecuted instance.

Method Summary

Modifier and Type	Method	Description
Conf	config()
String	description()
String	descriptionOrElseGet(String defaultValue)
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, withName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InternalExecuted

public InternalExecuted()

Creates a new InternalExecuted instance.

InternalExecuted

public InternalExecuted(Executed executed)

Creates a new InternalExecuted instance.

Parameters:

executed - the Executed instance.

Method Detail

name

public String name()

nameOrElseGet

public String nameOrElseGet(String defaultValue)

descriptionOrElseGet

public String descriptionOrElseGet(String defaultValue)

description

public String description()

config

public Conf config()

interceptors

public List<Supplier<StreamsLifecycleInterceptor>> interceptors()