Uses of Class
io.streamthoughts.azkarra.api.util.Version
-
-
Uses of Version in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return Version Modifier and Type Method Description default Version
StreamsLifecycleContext. topologyVersion()
Version
StreamsTopologyMeta. version()
Methods in io.streamthoughts.azkarra.api that return types with arguments of type Version Modifier and Type Method Description List<Version>
AzkarraStreamsService. getTopologyVersionsByAlias(String alias)
Gets all versions ofTopologyDescriptor
for the specified alias.Methods in io.streamthoughts.azkarra.api with parameters of type Version Modifier and Type Method Description StreamsTopologyMeta.Builder
StreamsTopologyMeta.Builder. setVersion(Version version)
-
Uses of Version in io.streamthoughts.azkarra.api.components
Methods in io.streamthoughts.azkarra.api.components that return Version Modifier and Type Method Description Version
ComponentDescriptor. version()
Gets the version of the described component.Version
SimpleComponentDescriptor. version()
Gets the version of the described component. -
Uses of Version in io.streamthoughts.azkarra.api.components.qualifier
Methods in io.streamthoughts.azkarra.api.components.qualifier with parameters of type Version Modifier and Type Method Description static <T> Qualifier<T>
Qualifiers. byVersion(Version version)
-
Uses of Version in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams with parameters of type Version Modifier and Type Method Description static TopologyProvider
TopologyProvider. of(org.apache.kafka.streams.Topology topology, Version version)
An helper method to create a staticTopologyProvider
returning the providedTopology
. -
Uses of Version in io.streamthoughts.azkarra.api.util
Methods in io.streamthoughts.azkarra.api.util that return Version Modifier and Type Method Description static Version
Version. getLatest(Version... versions)
Static helper for returning the latest version from a list ofVersion
.static Version
Version. parse(String version)
Static helper for creating a new version based on the specified string.Methods in io.streamthoughts.azkarra.api.util with parameters of type Version Modifier and Type Method Description int
Version. compareTo(Version that)
static Version
Version. getLatest(Version... versions)
Static helper for returning the latest version from a list ofVersion
.static boolean
Version. isEqual(Version v1, String v2)
-
Uses of Version in io.streamthoughts.azkarra.runtime.components
Methods in io.streamthoughts.azkarra.runtime.components that return Version Modifier and Type Method Description Version
ComponentDescriptorBuilder. version()
Gets the version of the described component. -
Uses of Version in io.streamthoughts.azkarra.runtime.env
Methods in io.streamthoughts.azkarra.runtime.env with parameters of type Version Modifier and Type Method Description LocalStreamsExecutionEnvironment
LocalStreamsExecutionEnvironment. registerTopology(org.apache.kafka.streams.Topology topology, Version version, Executed executed)
Registers a newTopologyProvider
instance to thisStreamsExecutionEnvironment
. -
Uses of Version in io.streamthoughts.azkarra.runtime.service
Methods in io.streamthoughts.azkarra.runtime.service that return types with arguments of type Version Modifier and Type Method Description List<Version>
AbstractAzkarraStreamsService. getTopologyVersionsByAlias(String alias)
Gets all versions ofTopologyDescriptor
for the specified alias.
-