Class DelegatingExecutionEnvironmentAware<T>
- java.lang.Object
-
- io.streamthoughts.azkarra.runtime.context.internal.DelegatingExecutionEnvironmentAware<T>
-
- All Implemented Interfaces:
StreamsExecutionEnvironmentAware
- Direct Known Subclasses:
ClassLoaderAwareKafkaStreamsFactory
,ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder
,ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory
,ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler
,ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider
public class DelegatingExecutionEnvironmentAware<T> extends Object implements StreamsExecutionEnvironmentAware
A delegatingStreamsExecutionEnvironmentAware
implementation.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)
Set theStreamsExecutionEnvironment
.
-
-
-
Method Detail
-
setExecutionEnvironment
public void setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)
Set theStreamsExecutionEnvironment
.- Specified by:
setExecutionEnvironment
in interfaceStreamsExecutionEnvironmentAware
- Parameters:
environment
- theStreamsExecutionEnvironment
instance
-
-