LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.addConfiguration(Supplier<Conf> configuration) |
Adds a new configuration to this environment.
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.addFallbackConfiguration(Conf fallback) |
Adds settings to this environment that will be used in fallback if not present
in the defined environment configuration.
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.addGlobalStateListener(org.apache.kafka.streams.processor.StateRestoreListener listener) |
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.addStateListener(org.apache.kafka.streams.KafkaStreams.StateListener listener) |
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.addStreamsConfiguration(Supplier<Conf> configuration) |
Helper method to add a configuration prefixed with 'streams.'.
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.addStreamsLifecycleInterceptor(Supplier<StreamsLifecycleInterceptor> interceptor) |
|
static LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.create() |
Static helper that can be used to creates a new StreamsExecutionEnvironment instance
using the empty configuration and a generated unique name.
|
static LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.create(Conf settings) |
|
static LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.create(String name) |
Static helper that can be used to creates a new StreamsExecutionEnvironment instance from
the specified env name and using the configuration.
|
static LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.create(String name,
Conf settings) |
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironmentFactory.create(String name,
Conf conf) |
Creates a new StreamsExecutionEnvironment from the specified name and configuration.
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.isDefault(boolean isDefault) |
Sets whether this execution environment should be the default.
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.registerTopology(Supplier<TopologyProvider> supplier) |
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.registerTopology(Supplier<TopologyProvider> supplier,
Executed executed) |
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.registerTopology(org.apache.kafka.streams.Topology topology,
Version version,
Executed executed) |
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.setApplicationIdBuilder(Supplier<ApplicationIdBuilder> supplier) |
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.setKafkaStreamsFactory(Supplier<KafkaStreamsFactory> factory) |
Sets the KafkaStreamsFactory that will be used to provide
the KafkaStreams to configure and start.
|
LocalStreamsExecutionEnvironment |
LocalStreamsExecutionEnvironment.setStreamThreadExceptionHandler(Supplier<StreamThreadExceptionHandler> handler) |
|