Uses of Interface
io.streamthoughts.azkarra.api.model.HasName
-
Packages that use HasName Package Description io.streamthoughts.azkarra.api io.streamthoughts.azkarra.api.model io.streamthoughts.azkarra.api.streams.store io.streamthoughts.azkarra.runtime.env -
-
Uses of HasName in io.streamthoughts.azkarra.api
Subinterfaces of HasName in io.streamthoughts.azkarra.api Modifier and Type Interface Description interface
StreamsExecutionEnvironment<T extends StreamsExecutionEnvironment<T>>
AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely.Classes in io.streamthoughts.azkarra.api that implement HasName Modifier and Type Class Description static class
StreamsExecutionEnvironment.View
AEnvironment
is used to describe the current state of aStreamsExecutionEnvironment
instance. -
Uses of HasName in io.streamthoughts.azkarra.api.model
Methods in io.streamthoughts.azkarra.api.model with type parameters of type HasName Modifier and Type Method Description static <T extends HasName>
Optional<T>HasName. filterByName(Collection<T> collections, String name)
An helper method to filter aCollection
ofHasName
object based on its name.Method parameters in io.streamthoughts.azkarra.api.model with type arguments of type HasName Modifier and Type Method Description static Set<String>
HasName. getIds(Collection<? extends HasName> collections)
An helper method to get string names from a collection ofHasName
objects. -
Uses of HasName in io.streamthoughts.azkarra.api.streams.store
Classes in io.streamthoughts.azkarra.api.streams.store that implement HasName Modifier and Type Class Description class
LocalStatePartitionsInfo
TheLocalStatePartitionsInfo
describes the state of a state store. -
Uses of HasName in io.streamthoughts.azkarra.runtime.env
Classes in io.streamthoughts.azkarra.runtime.env that implement HasName Modifier and Type Class Description class
LocalStreamsExecutionEnvironment
AStreamsExecutionEnvironment
implementation that runs and managesKafkaStreams
instance locally.
-