Uses of Interface
io.streamthoughts.azkarra.api.streams.TopologyProvider
-
-
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 newTopologyProvider
instance to thisStreamsExecutionEnvironment
to be started.ApplicationId
StreamsExecutionEnvironment. addTopology(Supplier<TopologyProvider> provider, Executed executed)
Add a newTopologyProvider
instance to thisStreamsExecutionEnvironment
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>
AComponentDescriptor
for describing aTopologyProvider
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
ATopologyProvider
that can be used to build an optimizedTopology
instance. -
Uses of TopologyProvider in io.streamthoughts.azkarra.runtime.components
Methods in io.streamthoughts.azkarra.runtime.components that return types with arguments of type TopologyProvider Modifier and Type Method Description ComponentDescriptor<TopologyProvider>
TopologyDescriptorFactory. make(Class<? extends TopologyProvider> type, String version)
Makes a newComponentDescriptor
instance.Method parameters in io.streamthoughts.azkarra.runtime.components with type arguments of type TopologyProvider Modifier and Type Method Description ComponentDescriptor<TopologyProvider>
TopologyDescriptorFactory. make(Class<? extends TopologyProvider> type, String version)
Makes a newComponentDescriptor
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.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 newTopologyProvider
instance to thisStreamsExecutionEnvironment
to be started.ApplicationId
DefaultStreamsExecutionEnvironment. addTopology(Supplier<TopologyProvider> provider, Executed executed)
Add a newTopologyProvider
instance to thisStreamsExecutionEnvironment
to be started. -
Uses of TopologyProvider in io.streamthoughts.azkarra.runtime.streams.topology
Methods in io.streamthoughts.azkarra.runtime.streams.topology with parameters of type TopologyProvider Modifier and Type Method Description TopologyContainer
TopologyFactory. make(TopologyProvider provider, Conf defaultConf, Executed executed)
Makes aTopology
instance using the specifiedTopologyDescriptor
. -
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.
-