Class EnvironmentConfig
- java.lang.Object
-
- io.streamthoughts.azkarra.streams.context.internal.EnvironmentConfig
-
public class EnvironmentConfig extends Object
Class which is used to configure aStreamsExecutionEnvironment
instance.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
EnvironmentConfig.Reader
-
Field Summary
Fields Modifier and Type Field Description static String
ENVIRONMENT_CONFIG
static String
ENVIRONMENT_NAME_CONFIG
static String
ENVIRONMENT_STREAMS_CONFIG
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Conf
config()
Gets the configuration for this environment.String
name()
Gets the environment name.static EnvironmentConfig
read(Conf conf)
Static helper that can be used to creates a newEnvironmentConfig
instance from the providedConf
.List<TopologyConfig>
topologyStreamConfigs()
Gets all the topology streams configurations for this environment.
-
-
-
Field Detail
-
ENVIRONMENT_CONFIG
public static final String ENVIRONMENT_CONFIG
- See Also:
- Constant Field Values
-
ENVIRONMENT_NAME_CONFIG
public static final String ENVIRONMENT_NAME_CONFIG
- See Also:
- Constant Field Values
-
ENVIRONMENT_STREAMS_CONFIG
public static final String ENVIRONMENT_STREAMS_CONFIG
- See Also:
- Constant Field Values
-
-
Method Detail
-
read
public static EnvironmentConfig read(Conf conf)
Static helper that can be used to creates a newEnvironmentConfig
instance from the providedConf
.- Returns:
- a new
EnvironmentConfig
instance.
-
name
public String name()
Gets the environment name.- Returns:
- a string name.
-
topologyStreamConfigs
public List<TopologyConfig> topologyStreamConfigs()
Gets all the topology streams configurations for this environment.- Returns:
- a
Conf
instance. Can be empty if no streams is defined for this environment.
-
-