com.twitter.heron.spi.utils

Class SchedulerConfig

java.lang.Object

com.twitter.heron.spi.utils.SchedulerConfig

public final class SchedulerConfig
extends java.lang.Object

For loading scheduler config

Method Summary

Modifier and Type	Method and Description
protected static Config	commandLineConfigs(java.lang.String cluster, java.lang.String role, java.lang.String environ) Load the config parameters from the command line
static Config	loadConfig(java.lang.String cluster, java.lang.String role, java.lang.String environ, java.lang.String topologyJarFile, java.lang.String topologyDefnFile, TopologyAPI.Topology topology)
protected static Config	sandboxConfigs() Load the defaults config
protected static Config	topologyConfigs(java.lang.String topologyJarFile, java.lang.String topologyDefnFile, TopologyAPI.Topology topology) Load the topology config

Methods inherited from class java.lang.Object

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

Method Detail

topologyConfigs

protected static Config topologyConfigs(java.lang.String topologyJarFile,
                                        java.lang.String topologyDefnFile,
                                        TopologyAPI.Topology topology)

Load the topology config

Parameters:

topologyJarFile, - name of the user submitted topology jar/tar file

topologyDefnFile, - name of the topology defintion file

topology, - proto in memory version of topology definition

Returns:

config, the topology config

sandboxConfigs

protected static Config sandboxConfigs()

Load the defaults config

return config, the defaults config

commandLineConfigs

protected static Config commandLineConfigs(java.lang.String cluster,
                                           java.lang.String role,
                                           java.lang.String environ)

Load the config parameters from the command line

Parameters:

cluster, - name of the cluster

role, - user role

environ, - user provided environment/tag

Returns:

config, the command line config

loadConfig

public static Config loadConfig(java.lang.String cluster,
                                java.lang.String role,
                                java.lang.String environ,
                                java.lang.String topologyJarFile,
                                java.lang.String topologyDefnFile,
                                TopologyAPI.Topology topology)