Package io.streamthoughts.azkarra.runtime.streams.topology

Class TopologyFactory

java.lang.Object

io.streamthoughts.azkarra.runtime.streams.topology.TopologyFactory

public class TopologyFactory
extends Object

TopologyFactory.

Constructor Summary

Constructors

Constructor	Description
TopologyFactory(StreamsExecutionEnvironment environment)	Creates a new TopologyFactory instance.

Method Summary

Modifier and Type	Method	Description
TopologyContainer	make(TopologyProvider provider, Conf defaultConf, Executed executed)	Makes a Topology instance using the specified TopologyDescriptor.

Methods inherited from class java.lang.Object

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

Constructor Detail

TopologyFactory

public TopologyFactory(StreamsExecutionEnvironment environment)

Creates a new TopologyFactory instance.

Parameters:

environment - the StreamsExecutionEnvironment instance.

Method Detail

make

public TopologyContainer make(TopologyProvider provider,
                              Conf defaultConf,
                              Executed executed)

Makes a Topology instance using the specified TopologyDescriptor.

Parameters:

provider - the TopologyProvider instance.

defaultConf - the Conf instance to be used for configuring the topology.

executed - the Executed instance.

Returns:

a new Topology instance.