Package io.streamthoughts.azkarra.runtime.env.internal

Class TopologyContainerFactory

java.lang.Object

io.streamthoughts.azkarra.runtime.env.internal.TopologyContainerFactory

public class TopologyContainerFactory
extends Object

TopologyContainerFactory.

Constructor Summary

Constructors

Constructor	Description
TopologyContainerFactory(StreamsExecutionEnvironment environment, Supplier<ApplicationIdBuilder> applicationIdBuilderSupplier)	Creates a new TopologyContainerFactory instance.

Method Summary

Modifier and Type	Method	Description
TopologyContainer	make(Supplier<TopologyProvider> providerSupplier, Executed executed)	Makes a Topology instance using the specified TopologyDescriptor.
void	setApplicationIdBuilder(Supplier<ApplicationIdBuilder> applicationIdBuilderSupplier)

Methods inherited from class java.lang.Object

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

Constructor Detail

TopologyContainerFactory

public TopologyContainerFactory(StreamsExecutionEnvironment environment,
                                Supplier<ApplicationIdBuilder> applicationIdBuilderSupplier)

Creates a new TopologyContainerFactory instance.

Parameters:

environment - the StreamsExecutionEnvironment instance.

Method Detail

setApplicationIdBuilder

public void setApplicationIdBuilder(Supplier<ApplicationIdBuilder> applicationIdBuilderSupplier)

make

public TopologyContainer make(Supplier<TopologyProvider> providerSupplier,
                              Executed executed)

Makes a Topology instance using the specified TopologyDescriptor.

Parameters:

providerSupplier - the TopologyProvider instance.

executed - the Executed instance.

Returns:

a new Topology instance.