Package io.streamthoughts.azkarra.runtime.streams

Class DefaultApplicationIdBuilder

java.lang.Object

io.streamthoughts.azkarra.runtime.streams.DefaultApplicationIdBuilder

All Implemented Interfaces:

ApplicationIdBuilder, StreamsExecutionEnvironmentAware

public class DefaultApplicationIdBuilder
extends Object
implements ApplicationIdBuilder, StreamsExecutionEnvironmentAware

The default ApplicationIdBuilder implementation.

Constructor Summary

Constructors

Constructor	Description
DefaultApplicationIdBuilder()

Method Summary

Modifier and Type	Method	Description
ApplicationId	buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)	Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.
void	setExecutionEnvironment(StreamsExecutionEnvironment environment)	Set the StreamsExecutionEnvironment.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultApplicationIdBuilder

public DefaultApplicationIdBuilder()

Method Detail

setExecutionEnvironment

public void setExecutionEnvironment(StreamsExecutionEnvironment environment)

Set the StreamsExecutionEnvironment.

Specified by:

setExecutionEnvironment in interface StreamsExecutionEnvironmentAware

Parameters:

environment - the StreamsExecutionEnvironment instance

buildApplicationId

public ApplicationId buildApplicationId(TopologyMetadata metadata,
                                        Conf streamsConfig)

Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.

Specified by:

buildApplicationId in interface ApplicationIdBuilder

Parameters:

metadata - the TopologyMetadata instance.

Returns:

a new ApplicationId instance.