Package io.streamthoughts.azkarra.runtime

Class StreamsExecutionEnvironmentAbstractFactory

java.lang.Object

io.streamthoughts.azkarra.runtime.StreamsExecutionEnvironmentAbstractFactory

public class StreamsExecutionEnvironmentAbstractFactory
extends Object

Constructor Summary

Constructors

Constructor	Description
StreamsExecutionEnvironmentAbstractFactory(Collection<StreamsExecutionEnvironmentFactory> factories)	Creates a new StreamsExecutionEnvironmentAbstractFactory instance.

Method Summary

Modifier and Type	Method	Description
void	addFactory(StreamsExecutionEnvironmentFactory<?> factory)	Adds a new StreamsExecutionEnvironmentFactory to this one.
StreamsExecutionEnvironment<?>	create(String type, String name, Conf conf)	Creates a new StreamsExecutionEnvironment for the specified type using the given name and configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamsExecutionEnvironmentAbstractFactory

public StreamsExecutionEnvironmentAbstractFactory(Collection<StreamsExecutionEnvironmentFactory> factories)

Creates a new StreamsExecutionEnvironmentAbstractFactory instance.

Parameters:

factories - all the StreamsExecutionEnvironmentFactory.

Method Detail

create

public StreamsExecutionEnvironment<?> create(String type,
                                             String name,
                                             Conf conf)

Creates a new StreamsExecutionEnvironment for the specified type using the given name and configuration.

Parameters:

type - the environment type.

name - the environment name.

conf - the environment configuration.

Returns:

a new StreamsExecutionEnvironment.

addFactory

public void addFactory(StreamsExecutionEnvironmentFactory<?> factory)

Adds a new StreamsExecutionEnvironmentFactory to this one.

Parameters:

factory - the StreamsExecutionEnvironmentFactory to be added.