public class Config
extends java.util.HashMap<java.lang.String,java.lang.Object>
Note that you may put other configurations in any of the configs. Heron will ignore anything it doesn't recognize, but your topologies are free to make use of them by reading them in the prepare method of Bolts or the open method of Spouts. .
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
TOPOLOGY_ADDITIONAL_CLASSPATH
Any user defined classpath that needs to be passed to instances should be set in to config
through this key.
|
static java.lang.String |
TOPOLOGY_AUTO_TASK_HOOKS
A list of task hooks that are automatically added to every spout and bolt in the topology.
|
static java.lang.String |
TOPOLOGY_CAP_TICKET
Cap ticket (if filed) for the topology.
|
static java.lang.String |
TOPOLOGY_COMPONENT_JVMOPTS
Per component jvm options.
|
static java.lang.String |
TOPOLOGY_COMPONENT_PARALLELISM
The per componentparallelism for a component in this topology.
|
static java.lang.String |
TOPOLOGY_COMPONENT_RAMMAP
Per component ram requirement.
|
static java.lang.String |
TOPOLOGY_CONTAINER_CPU_REQUESTED
Number of cpu cores per container to be reserved for this topology
|
static java.lang.String |
TOPOLOGY_CONTAINER_DISK_REQUESTED
Amount of disk per container to be reserved for this topology.
|
static java.lang.String |
TOPOLOGY_CONTAINER_RAM_REQUESTED
Amount of ram per container to be reserved for this topology.
|
static java.lang.String |
TOPOLOGY_DEBUG
When set to true, Heron will log every message that's emitted.
|
static java.lang.String |
TOPOLOGY_ENABLE_ACKING
How many executors to spawn for ackers.
|
static java.lang.String |
TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS
True if Heron should timeout messages or not.
|
static java.lang.String |
TOPOLOGY_MAX_SPOUT_PENDING
The maximum number of tuples that can be pending on a spout task at any given time.
|
static java.lang.String |
TOPOLOGY_MESSAGE_TIMEOUT_SECS
The maximum amount of time given to the topology to fully process a message
emitted by a spout.
|
static java.lang.String |
TOPOLOGY_NAME
Name of the topology.
|
static java.lang.String |
TOPOLOGY_PROJECT_NAME
Project name of the topology, to help us with tagging which topologies are part of which project.
|
static java.lang.String |
TOPOLOGY_SERIALIZER_CLASSNAME
The serialization class that is used to serialize/deserialize tuples
|
static java.lang.String |
TOPOLOGY_STMGRS
The number of stmgr instances that should spin up to service this
topology.
|
static java.lang.String |
TOPOLOGY_TEAM_EMAIL
Email of the team which owns this topology.
|
static java.lang.String |
TOPOLOGY_TEAM_NAME
Name of the team which owns this topology.
|
static java.lang.String |
TOPOLOGY_TICK_TUPLE_FREQ_SECS
How often a tick tuple from the "__system" component and "__tick" stream should be sent
to tasks.
|
static java.lang.String |
TOPOLOGY_WORKER_CHILDOPTS
Topology-specific options for the worker child process.
|
Modifier and Type | Method and Description |
---|---|
void |
addClasspath(java.util.Map conf,
java.lang.String classpath) |
java.util.Set<java.lang.String> |
getApiVars() |
java.util.List<java.lang.String> |
getAutoTaskHooks() |
static java.util.List<java.lang.String> |
getAutoTaskHooks(java.util.Map conf) |
void |
setAutoTaskHooks(java.util.List<java.lang.String> hooks) |
static void |
setAutoTaskHooks(java.util.Map conf,
java.util.List<java.lang.String> hooks) |
static void |
setComponentJvmOptions(java.util.Map conf,
java.lang.String component,
java.lang.String jvmOptions) |
void |
setComponentJvmOptions(java.lang.String component,
java.lang.String jvmOptions) |
void |
setComponentParallelism(int parallelism) |
static void |
setComponentParallelism(java.util.Map conf,
int parallelism) |
static void |
setComponentRam(java.util.Map conf,
java.lang.String component,
long ramInBytes) |
void |
setComponentRam(java.lang.String component,
long ramInBytes) |
static void |
setComponentRamMap(java.util.Map conf,
java.lang.String ramMap) |
void |
setComponentRamMap(java.lang.String ramMap) |
void |
setContainerCpuRequested(float ncpus) |
static void |
setContainerCpuRequested(java.util.Map conf,
float ncpus) |
void |
setContainerDiskRequested(long nbytes) |
static void |
setContainerDiskRequested(java.util.Map conf,
long nbytes) |
void |
setContainerRamRequested(long nbytes) |
static void |
setContainerRamRequested(java.util.Map conf,
long nbytes) |
void |
setDebug(boolean isOn) |
static void |
setDebug(java.util.Map conf,
boolean isOn) |
void |
setEnableAcking(boolean acking) |
static void |
setEnableAcking(java.util.Map conf,
boolean acking) |
void |
setMaxSpoutPending(int max) |
static void |
setMaxSpoutPending(java.util.Map conf,
int max) |
void |
setMessageTimeoutSecs(int secs) |
static void |
setMessageTimeoutSecs(java.util.Map conf,
int secs) |
void |
setNumStmgrs(int stmgrs) |
static void |
setNumStmgrs(java.util.Map conf,
int stmgrs) |
static void |
setSerializationClassName(java.util.Map conf,
java.lang.String className) |
void |
setSerializationClassName(java.lang.String className) |
static void |
setTeamEmail(java.util.Map conf,
java.lang.String team_email) |
void |
setTeamEmail(java.lang.String team_email) |
static void |
setTeamName(java.util.Map conf,
java.lang.String team_name) |
void |
setTeamName(java.lang.String team_name) |
void |
setTickTupleFrequency(int seconds) |
static void |
setTickTupleFrequency(java.util.Map conf,
int seconds) |
static void |
setTopologyCapTicket(java.util.Map conf,
java.lang.String ticket) |
void |
setTopologyCapTicket(java.lang.String ticket) |
static void |
setTopologyProjectName(java.util.Map conf,
java.lang.String project) |
void |
setTopologyProjectName(java.lang.String project) |
clear, clone, containsKey, containsValue, entrySet, get, isEmpty, keySet, put, putAll, remove, size, values
public static java.lang.String TOPOLOGY_DEBUG
public static java.lang.String TOPOLOGY_STMGRS
public static java.lang.String TOPOLOGY_MESSAGE_TIMEOUT_SECS
public static java.lang.String TOPOLOGY_COMPONENT_PARALLELISM
public static java.lang.String TOPOLOGY_MAX_SPOUT_PENDING
public static final java.lang.String TOPOLOGY_WORKER_CHILDOPTS
public static java.lang.String TOPOLOGY_AUTO_TASK_HOOKS
public static final java.lang.String TOPOLOGY_COMPONENT_JVMOPTS
public static java.lang.String TOPOLOGY_SERIALIZER_CLASSNAME
public static final java.lang.String TOPOLOGY_TICK_TUPLE_FREQ_SECS
public static final java.lang.String TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS
public static java.lang.String TOPOLOGY_ENABLE_ACKING
If this is set to 0, then Heron will immediately ack tuples as soon as they come off the spout, effectively disabling reliability.
public static java.lang.String TOPOLOGY_CONTAINER_CPU_REQUESTED
public static java.lang.String TOPOLOGY_CONTAINER_RAM_REQUESTED
public static java.lang.String TOPOLOGY_CONTAINER_DISK_REQUESTED
public static java.lang.String TOPOLOGY_COMPONENT_RAMMAP
public static java.lang.String TOPOLOGY_NAME
public static java.lang.String TOPOLOGY_TEAM_NAME
public static java.lang.String TOPOLOGY_TEAM_EMAIL
public static java.lang.String TOPOLOGY_CAP_TICKET
public static java.lang.String TOPOLOGY_PROJECT_NAME
public static java.lang.String TOPOLOGY_ADDITIONAL_CLASSPATH
public static void setDebug(java.util.Map conf, boolean isOn)
public void setDebug(boolean isOn)
public static void setTeamName(java.util.Map conf, java.lang.String team_name)
public void setTeamName(java.lang.String team_name)
public static void setTeamEmail(java.util.Map conf, java.lang.String team_email)
public void setTeamEmail(java.lang.String team_email)
public static void setTopologyCapTicket(java.util.Map conf, java.lang.String ticket)
public void setTopologyCapTicket(java.lang.String ticket)
public static void setTopologyProjectName(java.util.Map conf, java.lang.String project)
public void setTopologyProjectName(java.lang.String project)
public static void setNumStmgrs(java.util.Map conf, int stmgrs)
public void setNumStmgrs(int stmgrs)
public static void setSerializationClassName(java.util.Map conf, java.lang.String className)
public void setSerializationClassName(java.lang.String className)
public static void setEnableAcking(java.util.Map conf, boolean acking)
public void setEnableAcking(boolean acking)
public static void setMessageTimeoutSecs(java.util.Map conf, int secs)
public void setMessageTimeoutSecs(int secs)
public static void setComponentParallelism(java.util.Map conf, int parallelism)
public void setComponentParallelism(int parallelism)
public static void setMaxSpoutPending(java.util.Map conf, int max)
public void setMaxSpoutPending(int max)
public static void setTickTupleFrequency(java.util.Map conf, int seconds)
public void setTickTupleFrequency(int seconds)
public void setContainerCpuRequested(float ncpus)
public static void setContainerCpuRequested(java.util.Map conf, float ncpus)
public void setContainerDiskRequested(long nbytes)
public static void setContainerDiskRequested(java.util.Map conf, long nbytes)
public void setContainerRamRequested(long nbytes)
public static void setContainerRamRequested(java.util.Map conf, long nbytes)
public void setComponentRamMap(java.lang.String ramMap)
public static void setComponentRamMap(java.util.Map conf, java.lang.String ramMap)
public void setComponentRam(java.lang.String component, long ramInBytes)
public static void setAutoTaskHooks(java.util.Map conf, java.util.List<java.lang.String> hooks)
public void setAutoTaskHooks(java.util.List<java.lang.String> hooks)
public static java.util.List<java.lang.String> getAutoTaskHooks(java.util.Map conf)
public java.util.List<java.lang.String> getAutoTaskHooks()
public static void setComponentRam(java.util.Map conf, java.lang.String component, long ramInBytes)
public void addClasspath(java.util.Map conf, java.lang.String classpath)
public void setComponentJvmOptions(java.lang.String component, java.lang.String jvmOptions)
public static void setComponentJvmOptions(java.util.Map conf, java.lang.String component, java.lang.String jvmOptions)
public java.util.Set<java.lang.String> getApiVars()