Uses of Class
io.streamthoughts.azkarra.api.ApplicationId
-
-
Uses of ApplicationId in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return ApplicationId Modifier and Type Method Description 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 that return types with arguments of type ApplicationId 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.Optional<ApplicationId>
AzkarraContext. addTopology(String type, Executed executed)
Adds a topology to the default environment of this context.Optional<ApplicationId>
AzkarraContext. addTopology(String type, String environment, Executed executed)
Adds a topology to a specified environment.Optional<ApplicationId>
AzkarraContext. addTopology(String type, String version, String environment, Executed executed)
Adds a topology to a specified environment.default Optional<ApplicationId>
StreamsTopologyExecution. call()
Set<ApplicationId>
StreamsExecutionEnvironment. getApplicationIds()
Returns all {ApplicationId
for active Kafka Streams applications.Optional<ApplicationId>
StreamsTopologyExecution. start()
Starts the streams-topology encapsulated by this object.Methods in io.streamthoughts.azkarra.api with parameters of type ApplicationId Modifier and Type Method Description Optional<KafkaStreamsApplication>
StreamsExecutionEnvironment. getApplicationById(ApplicationId id)
Gets theKafkaStreamsApplication
for the specifiedapplication.id
default void
StreamsExecutionEnvironment. stop(ApplicationId id, boolean cleanUp)
Stops all the streams instances for the specified application id.void
StreamsExecutionEnvironment. stop(ApplicationId id, boolean cleanUp, Duration timeout)
Stops all the streams instance for the specified application id.default void
StreamsExecutionEnvironment. terminate(ApplicationId id)
Terminates all streams container for the specifiedapplication.id
and remove the associated topology from this environment.void
StreamsExecutionEnvironment. terminate(ApplicationId id, Duration timeout)
Terminates all streams container for the specifiedapplication.id
and remove the associated topology from this environment. -
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 config)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration. -
Uses of ApplicationId in io.streamthoughts.azkarra.runtime.context
Methods in io.streamthoughts.azkarra.runtime.context that return types with arguments of type ApplicationId 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.Optional<ApplicationId>
DefaultAzkarraContext. addTopology(String type, Executed executed)
Adds a topology to the default environment of this context.Optional<ApplicationId>
DefaultAzkarraContext. addTopology(String type, String environment, Executed executed)
Adds a topology to a specified environment.Optional<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 theStreamsConfig.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 types with arguments of type ApplicationId Modifier and Type Method Description Optional<ApplicationId>
LocalStreamsExecutionEnvironment. addTopology(Supplier<TopologyProvider> supplier)
Adds a newTopologyProvider
instance to thisStreamsExecutionEnvironment
.Optional<ApplicationId>
LocalStreamsExecutionEnvironment. addTopology(Supplier<TopologyProvider> supplier, Executed executed)
Adds a newTopologyProvider
instance to thisStreamsExecutionEnvironment
.Set<ApplicationId>
LocalStreamsExecutionEnvironment. getApplicationIds()
Returns all {ApplicationId
for active Kafka Streams applications.Optional<ApplicationId>
LocalStreamsExecution. start()
Starts the streams-topology encapsulated by this object.Methods in io.streamthoughts.azkarra.runtime.env with parameters of type ApplicationId Modifier and Type Method Description ContainerId
ContainerIdBuilder. buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology.Optional<KafkaStreamsApplication>
LocalStreamsExecutionEnvironment. getApplicationById(ApplicationId id)
Gets theKafkaStreamsApplication
for the specifiedapplication.id
void
LocalStreamsExecutionEnvironment. stop(ApplicationId id, boolean cleanUp, Duration timeout)
Stops all the streams instance for the specified application id.void
LocalStreamsExecutionEnvironment. terminate(ApplicationId id, Duration timeout)
Terminates all streams container for the specifiedapplication.id
and remove the associated topology from this environment. -
Uses of ApplicationId in io.streamthoughts.azkarra.runtime.env.internal
Methods in io.streamthoughts.azkarra.runtime.env.internal with parameters of type ApplicationId Modifier and Type Method Description ContainerId
DefaultContainerIdBuilder. buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology. -
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 theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration.
-