Package io.streamthoughts.azkarra.runtime.context

Class DefaultAzkarraContext

java.lang.Object

io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext

All Implemented Interfaces:

AzkarraContext

public class DefaultAzkarraContext
extends Object
implements AzkarraContext

The AzkarraContext.

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_ENV_NAME

Method Summary

Modifier and Type	Method	Description
<T> AzkarraContext	addComponent(ComponentFactory<T> factory)	Registers a components into this context.
<T> AzkarraContext	addComponent(Class<T> cls)	Registers a components into this context.
AzkarraContext	addComponent(String className)	Registers a components into this context.
AzkarraContext	addConfiguration(Conf configuration)	Adds the specified Conf to the configuration of this AzkarraContext.
AzkarraContext	addExecutionEnvironment(StreamsExecutionEnvironment env)	Adds the StreamsExecutionEnvironment to this context.
AzkarraContext	addListener(AzkarraContextListener listener)	Registers a new listener instance to this context.
ApplicationId	addTopology(Class<? extends TopologyProvider> type, Executed executed)	Adds a topology to the default environment of this context.
ApplicationId	addTopology(Class<? extends TopologyProvider> type, String envName, Executed executed)	Adds a topology to a specified environment.
ApplicationId	addTopology(String type, Executed executed)	Adds a topology to the default environment of this context.
ApplicationId	addTopology(String type, String environment, Executed executed)	Adds a topology to a specified environment.
ApplicationId	addTopology(String type, String version, String environment, Executed executed)	Adds a topology to a specified environment.
static AzkarraContext	create()	Static helper that can be used to creates a new AzkarraContext instance using a default ComponentRegistry and a empty configuration.
static AzkarraContext	create(ComponentClassReader reader)	Static helper that can be used to creates a new AzkarraContext instance using the specified ComponentRegistry and a empty configuration.
static AzkarraContext	create(ComponentRegistry registry)	Static helper that can be used to creates a new AzkarraContext instance using the specified ComponentRegistry and a empty configuration.
static AzkarraContext	create(Conf configuration)	Static helper that can be used to creates a new AzkarraContext instance using a default ComponentRegistry and the specified configuration.
StreamsExecutionEnvironment	defaultExecutionEnvironment()	Gets the default StreamsExecutionEnvironment.
List<StreamsExecutionEnvironment>	environments()	Gets all StreamsExecutionEnvironment registered to this context.
<T> Collection<T>	getAllComponentForType(Class<T> cls)	Get all component instances for the specified class.
ComponentClassReader	getComponentClassReader()	Gets the internal ComponentClassReader.
<T> T	getComponentForType(Class<T> cls)	Gets a component instance for the specified class.
ComponentRegistry	getComponentRegistry()	Gets the internal ComponentRegistry.
Conf	getConfiguration()	Returns the global context streamsConfig of this AzkarraContext instance.
StreamsExecutionEnvironment	getEnvironmentForNameOrCreate(String envName)	Gets the StreamsExecutionEnvironment for the specified name or create a new one.
TopologyDescriptor	getTopology(String type)	Gets the topology for the specified class name or alias.
AzkarraContext	setComponentClassReader(ComponentClassReader reader)	Sets the internal the ComponentClassReader which is used for registering components to this context.
AzkarraContext	setComponentRegistry(ComponentRegistry registry)	Sets the internal the ComponentRegistry which is used for registering components to this context.
AzkarraContext	setConfiguration(Conf configuration)	Sets the default configuration to be used for this AzkarraContext.
AzkarraContext	setRegisterShutdownHook(boolean registerShutdownHook)	Sets if the created AzkarraContext should have a shutdown hook registered.
void	setState(State started)
void	start()	Starts this AzkarraContext instance.
void	stop()	Stops this AzkarraContext instance.
void	stop(boolean cleanUp)	Stops this AzkarraContext instance.
Set<TopologyDescriptor>	topologyProviders()	Gets all topologies registered into this AzkarraContext.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_ENV_NAME

public static final String DEFAULT_ENV_NAME

See Also:

Constant Field Values

Method Detail

create

public static AzkarraContext create()

Static helper that can be used to creates a new AzkarraContext instance using a default ComponentRegistry and a empty configuration.

Returns:

a new AzkarraContext instance.

create

public static AzkarraContext create(ComponentRegistry registry)

Static helper that can be used to creates a new AzkarraContext instance using the specified ComponentRegistry and a empty configuration.

Returns:

a new AzkarraContext instance.

create

public static AzkarraContext create(ComponentClassReader reader)

Static helper that can be used to creates a new AzkarraContext instance using the specified ComponentRegistry and a empty configuration.

Returns:

a new AzkarraContext instance.

create

public static AzkarraContext create(Conf configuration)

Static helper that can be used to creates a new AzkarraContext instance using a default ComponentRegistry and the specified configuration.

Returns:

a new AzkarraContext instance.

setComponentRegistry

public AzkarraContext setComponentRegistry(ComponentRegistry registry)

Sets the internal the ComponentRegistry which is used for registering components to this context.

Specified by:

setComponentRegistry in interface AzkarraContext

Parameters:

registry - the ComponentRegistry instance to be used.

Returns:

this AzkarraContext instance.

getComponentRegistry

public ComponentRegistry getComponentRegistry()

Gets the internal ComponentRegistry.

Specified by:

getComponentRegistry in interface AzkarraContext

Returns:

the ComponentRegistry instance to be used.

getComponentClassReader

public ComponentClassReader getComponentClassReader()

Gets the internal ComponentClassReader.

Specified by:

getComponentClassReader in interface AzkarraContext

Returns:

the ComponentClassReader instance to be used.

setComponentClassReader

public AzkarraContext setComponentClassReader(ComponentClassReader reader)

Sets the internal the ComponentClassReader which is used for registering components to this context.

Specified by:

setComponentClassReader in interface AzkarraContext

Parameters:

reader - the ComponentClassReader instance to be used.

Returns:

this AzkarraContext instance.

addListener

public AzkarraContext addListener(AzkarraContextListener listener)

Registers a new listener instance to this context.

Specified by:

addListener in interface AzkarraContext

Parameters:

listener - the AzkarraContextListener instance to register.

Returns:

this AzkarraContext instance.

setRegisterShutdownHook

public AzkarraContext setRegisterShutdownHook(boolean registerShutdownHook)

Sets if the created AzkarraContext should have a shutdown hook registered. Defaults to true to ensure that JVM shutdowns are handled gracefully.

Specified by:

setRegisterShutdownHook in interface AzkarraContext

Parameters:

registerShutdownHook - if the shutdown hook should be registered

Returns:

this AzkarraContext instance.

getConfiguration

public Conf getConfiguration()

Returns the global context streamsConfig of this AzkarraContext instance.

Specified by:

getConfiguration in interface AzkarraContext

Returns:

a Conf instance.

setConfiguration

public AzkarraContext setConfiguration(Conf configuration)

Sets the default configuration to be used for this AzkarraContext.

Specified by:

setConfiguration in interface AzkarraContext

Parameters:

configuration - the Conf instance.

Returns:

this AzkarraContext instance.

addConfiguration

public AzkarraContext addConfiguration(Conf configuration)

Adds the specified Conf to the configuration of this AzkarraContext.

Specified by:

addConfiguration in interface AzkarraContext

Parameters:

configuration - the Conf instance to be used.

Returns:

this AzkarraContext instance.

addExecutionEnvironment

public AzkarraContext addExecutionEnvironment(StreamsExecutionEnvironment env)
                                       throws AlreadyExistsException

Adds the StreamsExecutionEnvironment to this context.

Specified by:

addExecutionEnvironment in interface AzkarraContext

Parameters:

env - the StreamsExecutionEnvironment instance.

Returns:

this AzkarraContext instance.

Throws:

AlreadyExistsException - if a StreamsExecutionEnvironment is already registered for the given name.

addTopology

public ApplicationId addTopology(String type,
                                 Executed executed)

Adds a topology to the default environment of this context.

Specified by:

addTopology in interface AzkarraContext

Parameters:

type - the fully qualified class name or alias of the target TopologyProvider.

executed - the Executed instance.

Returns:

the ApplicationId instance if the environment is already started, otherwise null.

addTopology

public ApplicationId addTopology(Class<? extends TopologyProvider> type,
                                 Executed executed)

Adds a topology to the default environment of this context.

Specified by:

addTopology in interface AzkarraContext

Parameters:

type - the TopologyProvider class to add.

executed - the Executed instance.

Returns:

the ApplicationId instance if the environment is already started, otherwise null.

addTopology

public ApplicationId addTopology(Class<? extends TopologyProvider> type,
                                 String envName,
                                 Executed executed)

Adds a topology to a specified environment.

Specified by:

addTopology in interface AzkarraContext

Parameters:

type - the TopologyProvider class to add.

envName - the environment name.

executed - the Executed instance.

Returns:

the ApplicationId instance if the environment is already started, otherwise null..

addTopology

public ApplicationId addTopology(String type,
                                 String environment,
                                 Executed executed)

Adds a topology to a specified environment.

Specified by:

addTopology in interface AzkarraContext

Parameters:

type - the fully qualified class name or alias of the target TopologyProvider.

environment - the environment name.

executed - the Executed instance.

Returns:

the ApplicationId instance if the environment is already started, otherwise null.

addTopology

public ApplicationId addTopology(String type,
                                 String version,
                                 String environment,
                                 Executed executed)

Adds a topology to a specified environment.

Specified by:

addTopology in interface AzkarraContext

Parameters:

type - the fully qualified class name or alias of the target TopologyProvider.

version - the topology version.

environment - the environment name.

executed - the Executed instance.

Returns:

the ApplicationId instance if the environment is already started, otherwise null.

setState

public void setState(State started)

topologyProviders

public Set<TopologyDescriptor> topologyProviders()

Gets all topologies registered into this AzkarraContext. Note, if provider scan is enable then topologies will be scan when this AzkarraContext will be started.

Specified by:

topologyProviders in interface AzkarraContext

Returns:

a set of TopologyDescriptor.

environments

public List<StreamsExecutionEnvironment> environments()

Gets all StreamsExecutionEnvironment registered to this context.

Specified by:

environments in interface AzkarraContext

Returns:

a list of StreamsExecutionEnvironment instance.

getEnvironmentForNameOrCreate

public StreamsExecutionEnvironment getEnvironmentForNameOrCreate(String envName)

Gets the StreamsExecutionEnvironment for the specified name or create a new one.

Specified by:

getEnvironmentForNameOrCreate in interface AzkarraContext

Parameters:

envName - the environment name.

Returns:

a StreamsExecutionEnvironment instance with the specified name.

defaultExecutionEnvironment

public StreamsExecutionEnvironment defaultExecutionEnvironment()

Gets the default StreamsExecutionEnvironment.

Specified by:

defaultExecutionEnvironment in interface AzkarraContext

Returns:

a StreamsExecutionEnvironment instance.

addComponent

public <T> AzkarraContext addComponent(Class<T> cls)

Registers a components into this context.

Specified by:

addComponent in interface AzkarraContext

Parameters:

cls - the component class.

Returns:

this AzkarraContext instance.

addComponent

public <T> AzkarraContext addComponent(ComponentFactory<T> factory)

Registers a components into this context.

Specified by:

addComponent in interface AzkarraContext

Parameters:

factory - the ComponentFactory instance.

Returns:

this AzkarraContext instance.

addComponent

public AzkarraContext addComponent(String className)

Registers a components into this context.

Specified by:

addComponent in interface AzkarraContext

Parameters:

className - the component class name.

Returns:

this AzkarraContext instance.

getComponentForType

public <T> T getComponentForType(Class<T> cls)

Gets a component instance for the specified class.

Specified by:

getComponentForType in interface AzkarraContext

Type Parameters:

T - the component type.

Parameters:

cls - the component class.

Returns:

the component instance of type AzkarraContext.

getAllComponentForType

public <T> Collection<T> getAllComponentForType(Class<T> cls)

Get all component instances for the specified class.

Specified by:

getAllComponentForType in interface AzkarraContext

Type Parameters:

T - the component type.

Parameters:

cls - the component class.

Returns:

the component instance of type AzkarraContext.

getTopology

public TopologyDescriptor getTopology(String type)

Gets the topology for the specified class name or alias.

Specified by:

getTopology in interface AzkarraContext

Parameters:

type - the topology type.

Returns:

the TopologyDescriptor.

start

public void start()

Starts this AzkarraContext instance.

Specified by:

start in interface AzkarraContext

stop

public void stop(boolean cleanUp)

Stops this AzkarraContext instance.

Specified by:

stop in interface AzkarraContext

Parameters:

cleanUp - if local states of each KafkaStreams instance must be cleanup.

See Also:

.

stop

public void stop()

Stops this AzkarraContext instance.

Specified by:

stop in interface AzkarraContext