Uses of Class
io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Packages that use LocalKafkaStreamsContainer Package Description io.streamthoughts.azkarra.runtime.query io.streamthoughts.azkarra.runtime.streams -
-
Uses of LocalKafkaStreamsContainer in io.streamthoughts.azkarra.runtime.query
Constructors in io.streamthoughts.azkarra.runtime.query with parameters of type LocalKafkaStreamsContainer Constructor Description DistributedQueryCall(LocalExecutableQuery<K,V> query, LocalKafkaStreamsContainer container, RemoteQueryCallFactory callFactory)
Creates a newDecorateQuery
instance.LocalQueryCall(LocalKafkaStreamsContainer container, LocalExecutableQuery<K,V> query)
Creates a newDecorateQuery
instance. -
Uses of LocalKafkaStreamsContainer in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams that return LocalKafkaStreamsContainer Modifier and Type Method Description LocalKafkaStreamsContainer
LocalKafkaStreamsContainerBuilder. build()
Builds aKafkaStreams
instance.
-