Uses of Interface
io.streamthoughts.azkarra.api.streams.TopologyProvider

Packages that use TopologyProvider

Package	Description
io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.api.providers
io.streamthoughts.azkarra.api.streams
io.streamthoughts.azkarra.runtime.context
io.streamthoughts.azkarra.runtime.context.internal
io.streamthoughts.azkarra.runtime.env
io.streamthoughts.azkarra.runtime.service
io.streamthoughts.examples.azkarra.conditional
io.streamthoughts.examples.azkarra.dependency
io.streamthoughts.examples.azkarra.sse
io.streamthoughts.examples.azkarra.topology

Uses of TopologyProvider in io.streamthoughts.azkarra.api

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

Modifier and Type	Method	Description
Class<TopologyProvider>	StreamsTopologyMeta.type()

Method parameters in io.streamthoughts.azkarra.api with type arguments of type TopologyProvider

Modifier and Type	Method	Description
Optional<ApplicationId>	AzkarraContext.addTopology(Class<? extends TopologyProvider> type, Executed executed)	Adds a topology to the default environment of this context.
Optional<ApplicationId>	AzkarraContext.addTopology(Class<? extends TopologyProvider> type, String environment, Executed executed)	Adds a topology to a specified environment.
StreamsTopologyMeta.Builder	StreamsTopologyMeta.Builder.from(TopologyDescriptor<TopologyProvider> descriptor)
TopologyDescriptor	AzkarraStreamsService.getTopologyByAliasAndQualifiers(String alias, Qualifier<? extends TopologyProvider> qualifier)	Gets the TopologyDescriptor for the specified alias and qualifier.
StreamsTopologyMeta.Builder	StreamsTopologyMeta.Builder.setType(Class<TopologyProvider> type)

Uses of TopologyProvider in io.streamthoughts.azkarra.api.providers

Classes in io.streamthoughts.azkarra.api.providers with type parameters of type TopologyProvider

Modifier and Type	Class	Description
class	TopologyDescriptor<T extends TopologyProvider>	A SimpleComponentDescriptor for describing a TopologyProvider implementation.

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

Classes in io.streamthoughts.azkarra.api.streams that implement TopologyProvider

Modifier and Type	Class	Description
class	OptimizedTopologyProvider	A TopologyProvider that can be used to build an optimized Topology instance.

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

Modifier and Type	Method	Description
static TopologyProvider	TopologyProvider.of(org.apache.kafka.streams.Topology topology, Version version)	An helper method to create a static TopologyProvider returning the provided Topology.

Uses of TopologyProvider in io.streamthoughts.azkarra.runtime.context

Method parameters in io.streamthoughts.azkarra.runtime.context with type arguments of type TopologyProvider

Modifier and Type	Method	Description
Optional<ApplicationId>	DefaultAzkarraContext.addTopology(Class<? extends TopologyProvider> type, Executed executed)	Adds a topology to the default environment of this context.
Optional<ApplicationId>	DefaultAzkarraContext.addTopology(Class<? extends TopologyProvider> type, String environment, Executed executed)	Adds a topology to a specified environment.

Uses of TopologyProvider in io.streamthoughts.azkarra.runtime.context.internal

Classes in io.streamthoughts.azkarra.runtime.context.internal that implement TopologyProvider

Modifier and Type	Class	Description
static class	ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider	A delegating TopologyProvider which is not Configurable.

Methods in io.streamthoughts.azkarra.runtime.context.internal that return TopologyProvider

Modifier and Type	Method	Description
TopologyProvider	ContextAwareTopologySupplier.get(Conf configs)

Uses of TopologyProvider in io.streamthoughts.azkarra.runtime.env

Method parameters in io.streamthoughts.azkarra.runtime.env with type arguments of type TopologyProvider

Modifier and Type	Method	Description
Optional<ApplicationId>	LocalStreamsExecutionEnvironment.addTopology(Supplier<TopologyProvider> supplier)	Adds a new TopologyProvider instance to this StreamsExecutionEnvironment.
Optional<ApplicationId>	LocalStreamsExecutionEnvironment.addTopology(Supplier<TopologyProvider> supplier, Executed executed)	Adds a new TopologyProvider instance to this StreamsExecutionEnvironment.
LocalStreamsExecutionEnvironment	LocalStreamsExecutionEnvironment.registerTopology(Supplier<TopologyProvider> supplier)	Registers a new TopologyProvider instance to this StreamsExecutionEnvironment.
LocalStreamsExecutionEnvironment	LocalStreamsExecutionEnvironment.registerTopology(Supplier<TopologyProvider> supplier, Executed executed)	Registers a new TopologyProvider instance to this StreamsExecutionEnvironment.

Uses of TopologyProvider in io.streamthoughts.azkarra.runtime.service

Method parameters in io.streamthoughts.azkarra.runtime.service with type arguments of type TopologyProvider

Modifier and Type	Method	Description
TopologyDescriptor	AbstractAzkarraStreamsService.getTopologyByAliasAndQualifiers(String alias, Qualifier<? extends TopologyProvider> qualifier)	Gets the TopologyDescriptor for the specified alias and qualifier.

Uses of TopologyProvider in io.streamthoughts.examples.azkarra.conditional

Classes in io.streamthoughts.examples.azkarra.conditional that implement TopologyProvider

Modifier and Type	Class	Description
static class	ConditionalStreamsApplication.NormalizeStreamsTopology

Uses of TopologyProvider in io.streamthoughts.examples.azkarra.dependency

Classes in io.streamthoughts.examples.azkarra.dependency that implement TopologyProvider

Modifier and Type	Class	Description
class	ComplexWordCountTopology

Uses of TopologyProvider in io.streamthoughts.examples.azkarra.sse

Classes in io.streamthoughts.examples.azkarra.sse that implement TopologyProvider

Modifier and Type	Class	Description
static class	ServerSentEventExample.WordCountPublisherTopology

Uses of TopologyProvider in io.streamthoughts.examples.azkarra.topology

Classes in io.streamthoughts.examples.azkarra.topology that implement TopologyProvider

Modifier and Type	Class	Description
class	BasicWordCountTopology	A basic WordCount topology.
class	ConfigurableWordCountTopology	A basic WordCount topology.