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.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
void	StreamsExecutionEnvironment.remove(ApplicationId id)	Stops the streams instance for the specified application id and remove the associated topology from this environment.
void	StreamsExecutionEnvironment.stop(ApplicationId id, boolean cleanUp)	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)	Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.

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

Modifier and Type	Method	Description
KafkaStreamContainerBuilder	KafkaStreamContainerBuilder.withApplicationId(ApplicationId applicationId)

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

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

Modifier and Type	Method	Description
Tuple<Conf,org.apache.kafka.streams.KafkaStreams>	TopologyContainer.buildKafkaStreams(ApplicationId applicationId, Conf defaultStreamsConfig)	Builds a new KafkaStreams for this Topology.

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.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)	Stops the streams instance for the specified application id and remove the associated topology from this environment.
void	DefaultStreamsExecutionEnvironment.stop(ApplicationId id, boolean cleanUp)	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)	Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.