Uses of Class
io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer

Packages that use KafkaStreamsContainer

Package	Description
io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.api.query
io.streamthoughts.azkarra.api.query.internal
io.streamthoughts.azkarra.api.streams
io.streamthoughts.azkarra.api.streams.errors
io.streamthoughts.azkarra.api.streams.internal
io.streamthoughts.azkarra.runtime.context.internal
io.streamthoughts.azkarra.runtime.env
io.streamthoughts.azkarra.runtime.service
io.streamthoughts.azkarra.runtime.streams.errors

Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.api

Methods in io.streamthoughts.azkarra.api that return KafkaStreamsContainer

Modifier and Type	Method	Description
KafkaStreamsContainer	AzkarraStreamsService.getStreamsById(String applicationId)	Returns the KafkaStreamsContainer for the specified streams application.

Methods in io.streamthoughts.azkarra.api that return types with arguments of type KafkaStreamsContainer

Modifier and Type	Method	Description
Collection<KafkaStreamsContainer>	StreamsExecutionEnvironment.applications()	Returns all KafkaStreams started applications.

Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.api.query

Methods in io.streamthoughts.azkarra.api.query with parameters of type KafkaStreamsContainer

Modifier and Type	Method	Description
default Try<List<KV<K,V>>>	LocalStoreQuery.execute(KafkaStreamsContainer container)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	LocalStoreQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
QueryResult<K,V>	DistributedQuery.query(KafkaStreamsContainer streams, Queried options)	Executes this interactive query for the given KafkaStreams instance.

Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.api.query.internal

Methods in io.streamthoughts.azkarra.api.query.internal with parameters of type KafkaStreamsContainer

Modifier and Type	Method	Description
Try<List<KV<String,Long>>>	KeyValueCountQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	PreparedQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query locally on the specified streams instance.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchKeyRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedKeyValueGetAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedKeyValueGetQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedKeyValueGetRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	TimestampedWindowFetchAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	TimestampedWindowFetchKeyRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedWindowFetchQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<Long,V>>>	TimestampedWindowFetchTimeRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	TimestampedWindowGetAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchKeyRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	WindowFetchQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<Long,V>>>	WindowFetchTimeRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowGetAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.

Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.api.streams

Methods in io.streamthoughts.azkarra.api.streams that return KafkaStreamsContainer

Modifier and Type	Method	Description
KafkaStreamsContainer	KafkaStreamContainerBuilder.build()	Builds a KafkaStreams instance.

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.

Uses of KafkaStreamsContainer in io.streamthoughts.azkarra.api.streams.internal

Methods in io.streamthoughts.azkarra.api.streams.internal that return KafkaStreamsContainer

Modifier and Type	Method	Description
KafkaStreamsContainer	InternalStreamsLifecycleContext.container()	Return the container that is running the current KafkaStreams instance.

Constructors in io.streamthoughts.azkarra.api.streams.internal with parameters of type KafkaStreamsContainer

Constructor	Description
InternalStreamsLifecycleContext(KafkaStreamsContainer container)	Creates a new InternalStreamsLifecycleContext instance.

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>	DefaultStreamsExecutionEnvironment.applications()	Returns all KafkaStreams started applications.

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.getStreamsById(String applicationId)	Returns the KafkaStreamsContainer for the specified streams application.

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.