Package io.streamthoughts.azkarra.api
Interface StreamsExecutionEnvironmentFactory<T extends StreamsExecutionEnvironment<T>>
-
- All Known Implementing Classes:
LocalStreamsExecutionEnvironmentFactory
public interface StreamsExecutionEnvironmentFactory<T extends StreamsExecutionEnvironment<T>>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default T
create(String name)
Creates a new StreamsExecutionEnvironment from the specified name and an empty configuration.T
create(String name, Conf conf)
Creates a new StreamsExecutionEnvironment from the specified name and configuration.String
type()
Returns the string type associated with theStreamsExecutionEnvironment
that can be created from this factory.
-
-
-
Method Detail
-
create
default T create(String name)
Creates a new StreamsExecutionEnvironment from the specified name and an empty configuration.- Parameters:
name
- the environment name.- Returns:
- a new
StreamsExecutionEnvironment
of typeStreamsExecutionEnvironmentFactory
.
-
create
T create(String name, Conf conf)
Creates a new StreamsExecutionEnvironment from the specified name and configuration.- Parameters:
name
- the environment name.conf
- the environment configuration.- Returns:
- a new
StreamsExecutionEnvironment
of typeStreamsExecutionEnvironmentFactory
.
-
type
String type()
Returns the string type associated with theStreamsExecutionEnvironment
that can be created from this factory.- Returns:
- the type of the
StreamsExecutionEnvironment
.
-
-