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

Packages that use StreamsExecutionEnvironment

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

Uses of StreamsExecutionEnvironment in io.streamthoughts.azkarra.api

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

Modifier and Type	Method	Description
StreamsExecutionEnvironment	StreamsExecutionEnvironment.addFallbackConfiguration(Conf settings)	Adds streamsConfig that will be used in fallback if not present in defined environment streamsConfig.
StreamsExecutionEnvironment	StreamsExecutionEnvironment.addGlobalStateListener(org.apache.kafka.streams.processor.StateRestoreListener listener)	Adds a StateRestoreListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
StreamsExecutionEnvironment	StreamsExecutionEnvironment.addStateListener(org.apache.kafka.streams.KafkaStreams.StateListener listener)	Adds a KafkaStreams.StateListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
StreamsExecutionEnvironment	StreamsExecutionEnvironment.addStreamsLifecycleInterceptor(Supplier<StreamsLifecycleInterceptor> interceptor)	Adds a streams interceptor hat will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
StreamsExecutionEnvironment	AzkarraContext.defaultExecutionEnvironment()	Gets the default StreamsExecutionEnvironment.
StreamsExecutionEnvironment	AzkarraContext.getEnvironmentForNameOrCreate(String envName)	Gets the StreamsExecutionEnvironment for the specified name or create a new one.
StreamsExecutionEnvironment	StreamsExecutionEnvironment.setApplicationIdBuilder(Supplier<ApplicationIdBuilder> supplier)	Sets the ApplicationIdBuilder that should be used for building streams application.id.
StreamsExecutionEnvironment	StreamsExecutionEnvironment.setConfiguration(Conf configuration)	Sets this environment configuration.
StreamsExecutionEnvironment	StreamsExecutionEnvironment.setKafkaStreamsFactory(Supplier<KafkaStreamsFactory> kafkaStreamsFactory)	Sets the KafkaStreamsFactory that will be used to provide the KafkaStreams to configure and start.
StreamsExecutionEnvironment	StreamsExecutionEnvironment.setRocksDBConfig(RocksDBConfig settings)	Sets the RocksDBConfig streamsConfig used by topology persistent stores.
StreamsExecutionEnvironment	StreamsExecutionEnvironment.setStreamThreadExceptionHandler(Supplier<StreamThreadExceptionHandler> handler)	Sets the StreamThreadExceptionHandler invoked when a StreamThread abruptly terminates due to an uncaught exception.
StreamsExecutionEnvironment	StreamsExecutionEnvironment.setWaitForTopicsToBeCreated(boolean waitForTopicToBeCreated)	Sets if the streams instances should wait for topics source to be created before starting.

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

Modifier and Type	Method	Description
List<StreamsExecutionEnvironment>	AzkarraContext.environments()	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.
void	StreamsExecutionEnvironmentAware.setExecutionEnvironment(StreamsExecutionEnvironment environment)	Set the StreamsExecutionEnvironment.
Set<TopologyDescriptor>	AzkarraContext.topologyProviders(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

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

Modifier and Type	Method	Description
StreamsExecutionEnvironment	DefaultAzkarraContext.defaultExecutionEnvironment()	Gets the default StreamsExecutionEnvironment.
StreamsExecutionEnvironment	DefaultAzkarraContext.getEnvironmentForNameOrCreate(String envName)	Gets the StreamsExecutionEnvironment for the specified name or create a new one.

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

Modifier and Type	Method	Description
List<StreamsExecutionEnvironment>	DefaultAzkarraContext.environments()	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.topologyProviders(StreamsExecutionEnvironment env)	Gets all topologies registered into this AzkarraContext which are available for the given environment.

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	DefaultStreamsExecutionEnvironment	The default StreamsExecutionEnvironment implementation.

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

Modifier and Type	Method	Description
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.addFallbackConfiguration(Conf fallback)	Adds streamsConfig that will be used in fallback if not present in defined environment streamsConfig.
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.addGlobalStateListener(org.apache.kafka.streams.processor.StateRestoreListener listener)	Adds a StateRestoreListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.addStateListener(org.apache.kafka.streams.KafkaStreams.StateListener listener)	Adds a KafkaStreams.StateListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.addStreamsLifecycleInterceptor(Supplier<StreamsLifecycleInterceptor> interceptor)	Adds a streams interceptor hat will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
static StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.create()	Static helper that can be used to creates a new StreamsExecutionEnvironment instance using the empty configuration and a generated unique name.
static StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.create(Conf settings)	Static helper that can be used to creates a new StreamsExecutionEnvironment instance from the specified Conf and using a generated env name.
static StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.create(Conf settings, String envName)	Static helper that can be used to creates a new StreamsExecutionEnvironment instance from the specified Conf and env name.
static StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.create(String envName)	Static helper that can be used to creates a new StreamsExecutionEnvironment instance from the specified env name and using the configuration.
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.setApplicationIdBuilder(Supplier<ApplicationIdBuilder> supplier)	Sets the ApplicationIdBuilder that should be used for building streams application.id.
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.setConfiguration(Conf configuration)	Sets this environment configuration.
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.setKafkaStreamsFactory(Supplier<KafkaStreamsFactory> kafkaStreamsFactory)	Sets the KafkaStreamsFactory that will be used to provide the KafkaStreams to configure and start.
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.setRocksDBConfig(RocksDBConfig rocksDBConfig)	Sets the RocksDBConfig streamsConfig used by topology persistent stores.
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.setStreamThreadExceptionHandler(Supplier<StreamThreadExceptionHandler> handler)	Sets the StreamThreadExceptionHandler invoked when a StreamThread abruptly terminates due to an uncaught exception.
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.setWaitForTopicsToBeCreated(boolean waitForTopicToBeCreated)	Sets if the streams instances should wait for topics source to be created before starting.

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)

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

Constructor	Description
TopologyContainerFactory(StreamsExecutionEnvironment environment, Supplier<ApplicationIdBuilder> applicationIdBuilderSupplier)	Creates a new TopologyContainerFactory instance.

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.