Uses of Interface
io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
-
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return KafkaStreamsContainer Modifier and Type Method Description KafkaStreamsContainer
StreamsLifecycleContext. container()
default KafkaStreamsContainer
StreamsExecutionEnvironment. getContainerById(ContainerId id)
Gets aKafkaStreamsContainer
for the specified id.KafkaStreamsContainer
AzkarraStreamsService. getStreamsContainerById(String containerId)
Returns theKafkaStreamsContainer
for the specified id.Methods in io.streamthoughts.azkarra.api that return types with arguments of type KafkaStreamsContainer Modifier and Type Method Description Collection<KafkaStreamsContainer>
AzkarraStreamsService. getAllStreamsContainersById(String applicationId)
Returns all theKafkaStreamsContainer
for the specifiedapplication.id
.Collection<KafkaStreamsContainer>
StreamsExecutionEnvironment. getContainers()
Returns all containers for active Kafka Streams applications. -
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams with parameters of type KafkaStreamsContainer Modifier and Type Method Description void
KafkaStreamsContainerAware. setKafkaStreamsContainer(KafkaStreamsContainer container)
Sets the KafkaStreamsContainer that this object runs in. -
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.api.streams.errors
Methods in io.streamthoughts.azkarra.api.streams.errors with parameters of type KafkaStreamsContainer Modifier and Type Method Description void
StreamThreadExceptionHandler. handle(KafkaStreamsContainer container, Thread streamThread, Throwable e)
Method invoked when a StreamThread abruptly terminates due to an uncaught exception.Constructors in io.streamthoughts.azkarra.api.streams.errors with parameters of type KafkaStreamsContainer Constructor Description DelegatingUncaughtExceptionHandler(KafkaStreamsContainer container, StreamThreadExceptionHandler handler)
-
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.api.streams.listener
Methods in io.streamthoughts.azkarra.api.streams.listener with parameters of type KafkaStreamsContainer Modifier and Type Method Description void
CompositeStateListener. setKafkaStreamsContainer(KafkaStreamsContainer container)
Sets the KafkaStreamsContainer that this object runs in.void
CompositeStateRestoreListener. setKafkaStreamsContainer(KafkaStreamsContainer container)
Sets the KafkaStreamsContainer that this object runs in. -
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.runtime.context.internal
Methods in io.streamthoughts.azkarra.runtime.context.internal with parameters of type KafkaStreamsContainer Modifier and Type Method Description void
ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler. handle(KafkaStreamsContainer container, Thread streamThread, Throwable e)
Method invoked when a StreamThread abruptly terminates due to an uncaught exception. -
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.runtime.env
Methods in io.streamthoughts.azkarra.runtime.env that return types with arguments of type KafkaStreamsContainer Modifier and Type Method Description Collection<KafkaStreamsContainer>
LocalStreamsExecutionEnvironment. getContainers()
Returns all containers for active Kafka Streams applications. -
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.runtime.interceptors.monitoring
Methods in io.streamthoughts.azkarra.runtime.interceptors.monitoring with parameters of type KafkaStreamsContainer Modifier and Type Method Description void
KafkaMonitoringReporter. setKafkaStreamsContainer(KafkaStreamsContainer container)
Sets the KafkaStreamsContainer that this object runs in. -
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.runtime.query
Methods in io.streamthoughts.azkarra.runtime.query that return types with arguments of type KafkaStreamsContainer Modifier and Type Method Description Class<? extends KafkaStreamsContainer>
DistributedQueryExecutionDelegatee. supportedClass()
Gets theKafkaStreamsContainer
class that is supported by thisQueryExecutionDelegatee
.Class<? extends KafkaStreamsContainer>
QueryExecutionDelegatee. supportedClass()
Gets theKafkaStreamsContainer
class that is supported by thisQueryExecutionDelegatee
.Methods in io.streamthoughts.azkarra.runtime.query with parameters of type KafkaStreamsContainer Modifier and Type Method Description <K,V>
QueryResult<K,V>DistributedQueryExecutionDelegatee. execute(KafkaStreamsContainer container, QueryRequest queryRequest, QueryOptions queryOptions)
<K,V>
QueryResult<K,V>QueryExecutionDelegatee. execute(KafkaStreamsContainer container, QueryRequest queryRequest, QueryOptions queryOptions)
-
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.runtime.service
Methods in io.streamthoughts.azkarra.runtime.service that return KafkaStreamsContainer Modifier and Type Method Description KafkaStreamsContainer
LocalAzkarraStreamsService. getStreamsContainerById(String containerId)
Returns theKafkaStreamsContainer
for the specified id.Methods in io.streamthoughts.azkarra.runtime.service that return types with arguments of type KafkaStreamsContainer Modifier and Type Method Description Collection<KafkaStreamsContainer>
LocalAzkarraStreamsService. getAllStreamsContainersById(String applicationId)
Returns all theKafkaStreamsContainer
for the specifiedapplication.id
. -
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.runtime.streams
Classes in io.streamthoughts.azkarra.runtime.streams that implement KafkaStreamsContainer Modifier and Type Class Description class
LocalKafkaStreamsContainer
-
Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.runtime.streams.errors
Methods in io.streamthoughts.azkarra.runtime.streams.errors with parameters of type KafkaStreamsContainer Modifier and Type Method Description void
CloseKafkaStreamsOnThreadException. handle(KafkaStreamsContainer container, Thread streamThread, Throwable e)
Method invoked when a StreamThread abruptly terminates due to an uncaught exception.void
LogAndSkipOnThreadException. handle(KafkaStreamsContainer container, Thread streamThread, Throwable e)
Method invoked when a StreamThread abruptly terminates due to an uncaught exception.void
RestartKafkaStreamsOnThreadException. handle(KafkaStreamsContainer container, Thread streamThread, Throwable e)
Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
-