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.runtime.env
io.streamthoughts.azkarra.runtime.service

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
Try<List<KV<K,V>>>	LocalStoreQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
QueryResult<K,V>	DistributedQuery.query(KafkaStreamsContainer streams, Queried options)	Executes a state storeName query for specified arguments.

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, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetAllQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetRangeQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Either<List<KV<K,V>>,List<Error>>	PreparedQuery.execute(KafkaStreamsContainer container, Queried option)	Executes this query locally on the specified streams instance.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchKeyRangeQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchAllQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchKeyRangeQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	WindowFetchQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<Long,V>>>	WindowFetchTimeRangeQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowGetAllQuery.execute(KafkaStreamsContainer container, Queried queried)	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.

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

Modifier and Type	Method	Description
org.apache.kafka.streams.KafkaStreams	KafkaStreamsFactory.make(KafkaStreamsContainer container)	Creates a new KafkaStreams instance for the specified container.

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.