Package io.streamthoughts.azkarra.runtime.context.internal

Class ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider

java.lang.Object

io.streamthoughts.azkarra.runtime.context.internal.DelegatingExecutionEnvironmentAware<TopologyProvider>

io.streamthoughts.azkarra.runtime.context.internal.ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider

All Implemented Interfaces:

Versioned, EventStreamProvider, Provider<org.apache.kafka.streams.Topology>, TopologyProvider, StreamsExecutionEnvironmentAware

Enclosing class:

ContextAwareTopologySupplier

public static class ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider
extends DelegatingExecutionEnvironmentAware<TopologyProvider>
implements TopologyProvider, StreamsExecutionEnvironmentAware, EventStreamProvider

A delegating TopologyProvider which is not Configurable.

Method Summary

Modifier and Type	Method	Description
List<EventStream>	eventStreams()	Returns the list of EventStream
org.apache.kafka.streams.Topology	topology()	Supplies a new Kafka Streams Topology instance.
String	version()	Returns the version for this Topology.

Methods inherited from class io.streamthoughts.azkarra.runtime.context.internal.DelegatingExecutionEnvironmentAware

setExecutionEnvironment

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironmentAware

setExecutionEnvironment

Method Detail

version

public String version()

Returns the version for this Topology.

Specified by:

version in interface TopologyProvider

Specified by:

version in interface Versioned

Returns:

the string version.

topology

public org.apache.kafka.streams.Topology topology()

Supplies a new Kafka Streams Topology instance.

Specified by:

topology in interface Provider<org.apache.kafka.streams.Topology>

Specified by:

topology in interface TopologyProvider

Returns:

the Topology instance.

eventStreams

public List<EventStream> eventStreams()

Returns the list of EventStream

Specified by:

eventStreams in interface EventStreamProvider

Returns:

a list of EventStream. Must not return null.