com.twitter.heron.spi.utils

Class TopologyUtils

java.lang.Object

com.twitter.heron.spi.utils.TopologyUtils

public final class TopologyUtils
extends java.lang.Object

Utility to process TopologyAPI.Topology proto

Method Summary

Modifier and Type	Method and Description
static java.lang.String	getAdditionalClassPath(TopologyAPI.Topology topology)
static java.lang.String	getComponentJvmOptions(TopologyAPI.Topology topology)
static java.util.Map<java.lang.String,java.lang.Integer>	getComponentParallelism(TopologyAPI.Topology topology)
static java.util.Map<java.lang.String,ByteAmount>	getComponentRamMapConfig(TopologyAPI.Topology topology) Parses the value in Config.TOPOLOGY_COMPONENT_RAMMAP, and returns a map containing only component specified.
static ByteAmount	getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config, java.lang.String key, ByteAmount defaultValue)
static java.lang.Double	getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config, java.lang.String key, java.lang.Double defaultValue)
static java.lang.Integer	getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config, java.lang.String key, java.lang.Integer defaultValue)
static java.lang.Long	getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config, java.lang.String key, java.lang.Long defaultValue)
static java.lang.String	getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config, java.lang.String key, java.lang.String defaultValue)
static java.lang.String	getConfigWithException(java.util.List<TopologyAPI.Config.KeyValue> config, java.lang.String key)
static java.lang.String	getInstanceJvmOptions(TopologyAPI.Topology topology)
static int	getNumContainers(TopologyAPI.Topology topology)
static TopologyAPI.Topology	getTopology(java.lang.String topologyDefnFile)
static int	getTotalInstance(TopologyAPI.Topology topology)
static java.lang.String	lookUpTopologyDefnFile(java.lang.String dir, java.lang.String filename)
static java.lang.String	makeClassPath(TopologyAPI.Topology topology, java.lang.String originalPackageFile)
static boolean	verifyTopology(TopologyAPI.Topology topology) Verify if the given topology has all the necessary information

Methods inherited from class java.lang.Object

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

Method Detail

getTopology

public static TopologyAPI.Topology getTopology(java.lang.String topologyDefnFile)

getConfigWithDefault

public static java.lang.String getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config,
                                                    java.lang.String key,
                                                    java.lang.String defaultValue)

getConfigWithDefault

public static java.lang.Long getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config,
                                                  java.lang.String key,
                                                  java.lang.Long defaultValue)

getConfigWithDefault

public static java.lang.Integer getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config,
                                                     java.lang.String key,
                                                     java.lang.Integer defaultValue)

getConfigWithDefault

public static java.lang.Double getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config,
                                                    java.lang.String key,
                                                    java.lang.Double defaultValue)

getConfigWithDefault

public static ByteAmount getConfigWithDefault(java.util.List<TopologyAPI.Config.KeyValue> config,
                                              java.lang.String key,
                                              ByteAmount defaultValue)

getConfigWithException

public static java.lang.String getConfigWithException(java.util.List<TopologyAPI.Config.KeyValue> config,
                                                      java.lang.String key)

getComponentParallelism

public static java.util.Map<java.lang.String,java.lang.Integer> getComponentParallelism(TopologyAPI.Topology topology)

getInstanceJvmOptions

public static java.lang.String getInstanceJvmOptions(TopologyAPI.Topology topology)

getComponentJvmOptions

public static java.lang.String getComponentJvmOptions(TopologyAPI.Topology topology)

getTotalInstance

public static int getTotalInstance(TopologyAPI.Topology topology)

verifyTopology

public static boolean verifyTopology(TopologyAPI.Topology topology)

Verify if the given topology has all the necessary information

getAdditionalClassPath

public static java.lang.String getAdditionalClassPath(TopologyAPI.Topology topology)

getComponentRamMapConfig

public static java.util.Map<java.lang.String,ByteAmount> getComponentRamMapConfig(TopologyAPI.Topology topology)

Parses the value in Config.TOPOLOGY_COMPONENT_RAMMAP, and returns a map containing only component specified. Returns a empty map if the Config is not set

Parameters:

topology - the topology def

Returns:

a map (componentName -> ram required)

getNumContainers

public static int getNumContainers(TopologyAPI.Topology topology)

makeClassPath

public static java.lang.String makeClassPath(TopologyAPI.Topology topology,
                                             java.lang.String originalPackageFile)

lookUpTopologyDefnFile

public static java.lang.String lookUpTopologyDefnFile(java.lang.String dir,
                                                      java.lang.String filename)