Uses of Class
io.streamthoughts.azkarra.api.providers.TopologyDescriptor
-
-
Uses of TopologyDescriptor in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return TopologyDescriptor Modifier and Type Method Description TopologyDescriptor
AzkarraStreamsService. getTopologyByAliasAndQualifiers(String alias, Qualifier<? extends TopologyProvider> qualifier)
Gets theTopologyDescriptor
for the specified alias and qualifier.TopologyDescriptor
AzkarraStreamsService. getTopologyByAliasAndVersion(String alias, String version)
Gets theTopologyDescriptor
for the specified alias and version.Methods in io.streamthoughts.azkarra.api that return types with arguments of type TopologyDescriptor Modifier and Type Method Description Set<TopologyDescriptor>
AzkarraContext. getTopologyDescriptors()
Gets all topologies registered into thisAzkarraContext
even those ones which are not enable.Set<TopologyDescriptor>
AzkarraContext. getTopologyDescriptors(StreamsExecutionEnvironment<?> env)
Gets all topologies registered into thisAzkarraContext
which are available for the given environment.Set<TopologyDescriptor>
AzkarraContext. getTopologyDescriptors(String environmentName)
Gets all topologies registered into thisAzkarraContext
which are available for the given environment.Set<TopologyDescriptor>
AzkarraStreamsService. getTopologyProviders()
Gets all topologies available locally.Methods in io.streamthoughts.azkarra.api with parameters of type TopologyDescriptor Modifier and Type Method Description StreamsTopologyMeta.Builder
StreamsTopologyMeta.Builder. from(TopologyDescriptor<TopologyProvider> descriptor)
-
Uses of TopologyDescriptor in io.streamthoughts.azkarra.runtime.context
Methods in io.streamthoughts.azkarra.runtime.context that return types with arguments of type TopologyDescriptor Modifier and Type Method Description Set<TopologyDescriptor>
DefaultAzkarraContext. getTopologyDescriptors()
Gets all topologies registered into thisAzkarraContext
even those ones which are not enable.Set<TopologyDescriptor>
DefaultAzkarraContext. getTopologyDescriptors(StreamsExecutionEnvironment<?> env)
Gets all topologies registered into thisAzkarraContext
which are available for the given environment.Set<TopologyDescriptor>
DefaultAzkarraContext. getTopologyDescriptors(String environmentName)
Gets all topologies registered into thisAzkarraContext
which are available for the given environment. -
Uses of TopologyDescriptor in io.streamthoughts.azkarra.runtime.service
Methods in io.streamthoughts.azkarra.runtime.service that return TopologyDescriptor Modifier and Type Method Description TopologyDescriptor
AbstractAzkarraStreamsService. getTopologyByAliasAndQualifiers(String alias, Qualifier<? extends TopologyProvider> qualifier)
Gets theTopologyDescriptor
for the specified alias and qualifier.TopologyDescriptor
AbstractAzkarraStreamsService. getTopologyByAliasAndVersion(String alias, String version)
Gets theTopologyDescriptor
for the specified alias and version.Methods in io.streamthoughts.azkarra.runtime.service that return types with arguments of type TopologyDescriptor Modifier and Type Method Description Set<TopologyDescriptor>
AbstractAzkarraStreamsService. getTopologyProviders()
Gets all topologies available locally. -
Uses of TopologyDescriptor in io.streamthoughts.azkarra.serialization.json
Methods in io.streamthoughts.azkarra.serialization.json with parameters of type TopologyDescriptor Modifier and Type Method Description void
TopologyDescriptorSerializer. serialize(TopologyDescriptor descriptor, com.fasterxml.jackson.core.JsonGenerator gen, com.fasterxml.jackson.databind.SerializerProvider serializers)
-