Uses of Interface
io.streamthoughts.azkarra.api.StreamsExecutionEnvironment

Packages that use StreamsExecutionEnvironment

Package	Description
io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.runtime
io.streamthoughts.azkarra.runtime.context
io.streamthoughts.azkarra.runtime.context.internal
io.streamthoughts.azkarra.runtime.env
io.streamthoughts.azkarra.runtime.env.internal
io.streamthoughts.azkarra.runtime.interceptors
io.streamthoughts.azkarra.runtime.streams
io.streamthoughts.azkarra.runtime.streams.errors

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.api

Classes in io.streamthoughts.azkarra.api with type parameters of type StreamsExecutionEnvironment

Modifier and Type	Interface	Description
interface	StreamsExecutionEnvironment<T extends StreamsExecutionEnvironment<T>>	A StreamsExecutionEnvironment manages the execution and the lifecycle of one or many KafkaStreams instances that run either locally or remotely.
interface	StreamsExecutionEnvironmentFactory<T extends StreamsExecutionEnvironment<T>>

Methods in io.streamthoughts.azkarra.api that return StreamsExecutionEnvironment

Modifier and Type	Method	Description
StreamsExecutionEnvironment<?>	AzkarraContext.getDefaultEnvironment()	Gets the default StreamsExecutionEnvironment.
StreamsExecutionEnvironment<?>	AzkarraContext.getEnvironmentForName(String envName)	Gets the StreamsExecutionEnvironment for the specified name.

Methods in io.streamthoughts.azkarra.api that return types with arguments of type StreamsExecutionEnvironment

Modifier and Type	Method	Description
List<StreamsExecutionEnvironment<?>>	AzkarraContext.getAllEnvironments()	Gets all StreamsExecutionEnvironment registered to this context.

Methods in io.streamthoughts.azkarra.api with parameters of type StreamsExecutionEnvironment

Modifier and Type	Method	Description
AzkarraContext	AzkarraContext.addExecutionEnvironment(StreamsExecutionEnvironment<?> environment)	Adds the StreamsExecutionEnvironment to this context.
Set<TopologyDescriptor>	AzkarraContext.getTopologyDescriptors(StreamsExecutionEnvironment<?> env)	Gets all topologies registered into this AzkarraContext which are available for the given environment.
void	StreamsExecutionEnvironmentAware.setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)	Set the StreamsExecutionEnvironment.

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.runtime

Classes in io.streamthoughts.azkarra.runtime with type parameters of type StreamsExecutionEnvironment

Modifier and Type	Class	Description
class	AbstractTopologyStreamsExecution<E extends StreamsExecutionEnvironment<E>>

Fields in io.streamthoughts.azkarra.runtime declared as StreamsExecutionEnvironment

Modifier and Type	Field	Description
protected E	AbstractTopologyStreamsExecution.environment

Methods in io.streamthoughts.azkarra.runtime that return StreamsExecutionEnvironment

Modifier and Type	Method	Description
StreamsExecutionEnvironment<?>	StreamsExecutionEnvironmentAbstractFactory.create(String type, String name, Conf conf)	Creates a new StreamsExecutionEnvironment for the specified type using the given name and configuration.

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.runtime.context

Methods in io.streamthoughts.azkarra.runtime.context that return StreamsExecutionEnvironment

Modifier and Type	Method	Description
StreamsExecutionEnvironment<?>	DefaultAzkarraContext.getDefaultEnvironment()	Gets the default StreamsExecutionEnvironment.
StreamsExecutionEnvironment<?>	DefaultAzkarraContext.getEnvironmentForName(String name)	Gets the StreamsExecutionEnvironment for the specified name.

Methods in io.streamthoughts.azkarra.runtime.context that return types with arguments of type StreamsExecutionEnvironment

Modifier and Type	Method	Description
List<StreamsExecutionEnvironment<?>>	DefaultAzkarraContext.getAllEnvironments()	Gets all StreamsExecutionEnvironment registered to this context.

Methods in io.streamthoughts.azkarra.runtime.context with parameters of type StreamsExecutionEnvironment

Modifier and Type	Method	Description
AzkarraContext	DefaultAzkarraContext.addExecutionEnvironment(StreamsExecutionEnvironment<?> env)	Adds the StreamsExecutionEnvironment to this context.
Set<TopologyDescriptor>	DefaultAzkarraContext.getTopologyDescriptors(StreamsExecutionEnvironment<?> env)	Gets all topologies registered into this AzkarraContext which are available for the given environment.

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.runtime.context.internal

Methods in io.streamthoughts.azkarra.runtime.context.internal with parameters of type StreamsExecutionEnvironment

Modifier and Type	Method	Description
void	DelegatingExecutionEnvironmentAware.setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)	Set the StreamsExecutionEnvironment.

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.runtime.env

Classes in io.streamthoughts.azkarra.runtime.env that implement StreamsExecutionEnvironment

Modifier and Type	Class	Description
class	LocalStreamsExecutionEnvironment	A StreamsExecutionEnvironment implementation that runs and manages KafkaStreams instance locally.

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.runtime.env.internal

Methods in io.streamthoughts.azkarra.runtime.env.internal with parameters of type StreamsExecutionEnvironment

Modifier and Type	Method	Description
T	EnvironmentAwareComponentSupplier.get(StreamsExecutionEnvironment<?> environment, Conf componentConf)

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.runtime.interceptors

Methods in io.streamthoughts.azkarra.runtime.interceptors with parameters of type StreamsExecutionEnvironment

Modifier and Type	Method	Description
void	CompositeStreamsInterceptor.setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)	Set the StreamsExecutionEnvironment.

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.runtime.streams

Methods in io.streamthoughts.azkarra.runtime.streams with parameters of type StreamsExecutionEnvironment

Modifier and Type	Method	Description
void	DefaultApplicationIdBuilder.setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)	Set the StreamsExecutionEnvironment.

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.runtime.streams.errors

Methods in io.streamthoughts.azkarra.runtime.streams.errors with parameters of type StreamsExecutionEnvironment

Modifier and Type	Method	Description
void	CloseKafkaStreamsOnThreadException.setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)	Set the StreamsExecutionEnvironment.