Uses of Class
io.streamthoughts.azkarra.api.streams.ApplicationId

Packages that use ApplicationId

Package	Description
io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.api.streams
io.streamthoughts.azkarra.api.streams.topology
io.streamthoughts.azkarra.runtime.context
io.streamthoughts.azkarra.runtime.context.internal
io.streamthoughts.azkarra.runtime.env
io.streamthoughts.azkarra.runtime.service
io.streamthoughts.azkarra.runtime.streams

Uses of ApplicationId in io.streamthoughts.azkarra.api

Methods in io.streamthoughts.azkarra.api that return ApplicationId

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	AzkarraContext.addTopology(String type, Executed executed)	Adds a topology to the default environment of this context.
ApplicationId	AzkarraContext.addTopology(String type, String environment, Executed executed)	Adds a topology to a specified environment.
ApplicationId	AzkarraContext.addTopology(String type, String version, 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.
ApplicationId	AzkarraStreamsService.startStreamsTopology(String topologyType, String topologyVersion, String env, Executed executed)	Creates and starts a new streams job for the specified topology into the specified environment.

Methods in io.streamthoughts.azkarra.api with parameters of type ApplicationId

Modifier and Type	Method	Description
default void	StreamsExecutionEnvironment.remove(ApplicationId id)	Stops the streams instance for the specified application id and remove the associated topology from this environment.
void	StreamsExecutionEnvironment.remove(ApplicationId id, Duration timeout)	Stops the streams instance for the specified application id and remove the associated topology from this environment.
default void	StreamsExecutionEnvironment.stop(ApplicationId id, boolean cleanUp)	Stops the streams instance for the specified application id.
void	StreamsExecutionEnvironment.stop(ApplicationId id, boolean cleanUp, Duration timeout)	Stops the streams instance for the specified application id.

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

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

Modifier and Type	Method	Description
ApplicationId	ApplicationIdBuilder.buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)	Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.

Uses of ApplicationId in io.streamthoughts.azkarra.api.streams.topology

Methods in io.streamthoughts.azkarra.api.streams.topology that return ApplicationId

Modifier and Type	Method	Description
ApplicationId	TopologyContainer.applicationId()

Constructors in io.streamthoughts.azkarra.api.streams.topology with parameters of type ApplicationId

Constructor	Description
TopologyContainer(org.apache.kafka.streams.Topology topology, ApplicationId applicationId, Conf streamsConfig, TopologyMetadata metadata, List<StreamsLifecycleInterceptor> interceptors)	Creates a new TopologyContainer instance.

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

Methods in io.streamthoughts.azkarra.runtime.context that return ApplicationId

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.
ApplicationId	DefaultAzkarraContext.addTopology(String type, Executed executed)	Adds a topology to the default environment of this context.
ApplicationId	DefaultAzkarraContext.addTopology(String type, String environment, Executed executed)	Adds a topology to a specified environment.
ApplicationId	DefaultAzkarraContext.addTopology(String type, String version, String environment, Executed executed)	Adds a topology to a specified environment.

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

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

Modifier and Type	Method	Description
ApplicationId	ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder.buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)	Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.

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

Methods in io.streamthoughts.azkarra.runtime.env that return ApplicationId

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.

Methods in io.streamthoughts.azkarra.runtime.env with parameters of type ApplicationId

Modifier and Type	Method	Description
void	DefaultStreamsExecutionEnvironment.remove(ApplicationId id, Duration timeout)	Stops the streams instance for the specified application id and remove the associated topology from this environment.
void	DefaultStreamsExecutionEnvironment.stop(ApplicationId id, boolean cleanUp, Duration timeout)	Stops the streams instance for the specified application id.

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

Methods in io.streamthoughts.azkarra.runtime.service that return ApplicationId

Modifier and Type	Method	Description
ApplicationId	LocalAzkarraStreamsService.startStreamsTopology(String topologyType, String topologyVersion, String env, Executed executed)	Creates and starts a new streams job for the specified topology into the specified environment.

Uses of ApplicationId in io.streamthoughts.azkarra.runtime.streams

Methods in io.streamthoughts.azkarra.runtime.streams that return ApplicationId

Modifier and Type	Method	Description
ApplicationId	DefaultApplicationIdBuilder.buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)	Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.