Package io.streamthoughts.azkarra.api

Interface StreamsExecutionEnvironmentAware

All Known Implementing Classes:

ClassLoaderAwareKafkaStreamsFactory, CloseKafkaStreamsOnThreadException, CompositeStreamsInterceptor, ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder, ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory, ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler, ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider, DefaultApplicationIdBuilder, DelegatingExecutionEnvironmentAware

public interface StreamsExecutionEnvironmentAware

Method Summary

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

Method Detail

setExecutionEnvironment

void setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)

Set the StreamsExecutionEnvironment.

Parameters:

environment - the StreamsExecutionEnvironment instance