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.env.internal
io.streamthoughts.examples.azkarra.conditional
io.streamthoughts.examples.azkarra.dependency
io.streamthoughts.examples.azkarra.topology

Uses of TopologyProvider in io.streamthoughts.azkarra.api

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

Modifier and Type	Method	Description
ApplicationId	AzkarraContext.addTopology(Class<? extends TopologyProvider> type, Executed executed)	Adds a topology to the default environment of this context.
ApplicationId	AzkarraContext.addTopology(Class<? extends TopologyProvider> type, String environment, Executed executed)	Adds a topology to a specified environment.
ApplicationId	StreamsExecutionEnvironment.addTopology(Supplier<TopologyProvider> provider)	Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.
ApplicationId	StreamsExecutionEnvironment.addTopology(Supplier<TopologyProvider> provider, Executed executed)	Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.

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.

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
ApplicationId	DefaultAzkarraContext.addTopology(Class<? extends TopologyProvider> type, Executed executed)	Adds a topology to the default environment of this context.
ApplicationId	DefaultAzkarraContext.addTopology(Class<? extends TopologyProvider> type, String envName, 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.DelegateContextTopologyProvider	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)

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

Constructor	Description
ContextAwareTopologySupplier(AzkarraContext context, ComponentDescriptor<TopologyProvider> descriptor)	Creates a new ContextAwareTopologySupplier instance.

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
ApplicationId	DefaultStreamsExecutionEnvironment.addTopology(Supplier<TopologyProvider> provider)	Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.
ApplicationId	DefaultStreamsExecutionEnvironment.addTopology(Supplier<TopologyProvider> provider, Executed executed)	Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.

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

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

Modifier and Type	Method	Description
TopologyContainer	TopologyContainerFactory.make(Supplier<TopologyProvider> providerSupplier, Executed executed)	Makes a Topology instance using the specified TopologyDescriptor.

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.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.