Package io.streamthoughts.azkarra.runtime.env

Class LocalStreamsExecutionEnvironmentFactory

java.lang.Object

io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironmentFactory

All Implemented Interfaces:

AzkarraContextAware, StreamsExecutionEnvironmentFactory<LocalStreamsExecutionEnvironment>

public class LocalStreamsExecutionEnvironmentFactory
extends Object
implements StreamsExecutionEnvironmentFactory<LocalStreamsExecutionEnvironment>, AzkarraContextAware

The default StreamsExecutionEnvironment implementation.

Constructor Summary

Constructors

Constructor	Description
LocalStreamsExecutionEnvironmentFactory()

Method Summary

Modifier and Type	Method	Description
LocalStreamsExecutionEnvironment	create(String name, Conf conf)	Creates a new StreamsExecutionEnvironment from the specified name and configuration.
Optional<Supplier<ApplicationIdBuilder>>	findApplicationIdBuilder(Conf componentConfig, Restriction restriction)
Optional<Supplier<StreamThreadExceptionHandler>>	findStreamThreadExceptionHandler(Conf conf, Restriction restriction)
void	setAzkarraContext(AzkarraContext context)	Set the AzkarraContext that this object runs in.
String	type()	Returns the string type associated with the StreamsExecutionEnvironment that can be created from this factory.

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.StreamsExecutionEnvironmentFactory

create

Constructor Detail

LocalStreamsExecutionEnvironmentFactory

public LocalStreamsExecutionEnvironmentFactory()

Method Detail

create

public LocalStreamsExecutionEnvironment create(String name,
                                               Conf conf)

Creates a new StreamsExecutionEnvironment from the specified name and configuration.

Specified by:

create in interface StreamsExecutionEnvironmentFactory<LocalStreamsExecutionEnvironment>

Parameters:

name - the environment name.

conf - the environment configuration.

Returns:

a new StreamsExecutionEnvironment of type StreamsExecutionEnvironmentFactory.

type

public String type()

Returns the string type associated with the StreamsExecutionEnvironment that can be created from this factory.

Specified by:

type in interface StreamsExecutionEnvironmentFactory<LocalStreamsExecutionEnvironment>

Returns:

the type of the StreamsExecutionEnvironment.

setAzkarraContext

public void setAzkarraContext(AzkarraContext context)

Set the AzkarraContext that this object runs in.

Specified by:

setAzkarraContext in interface AzkarraContextAware

Parameters:

context - the AzkarraContext instance.

findApplicationIdBuilder

public Optional<Supplier<ApplicationIdBuilder>> findApplicationIdBuilder(Conf componentConfig,
                                                                         Restriction restriction)

findStreamThreadExceptionHandler

public Optional<Supplier<StreamThreadExceptionHandler>> findStreamThreadExceptionHandler(Conf conf,
                                                                                         Restriction restriction)