com.twitter.heron.api

Class HeronSubmitter

java.lang.Object

com.twitter.heron.api.HeronSubmitter

public class HeronSubmitter
extends java.lang.Object

Use this class to submit topologies to run on the Heron cluster. You should run your program with the "heron jar" command from the command-line, and then use this class to submit your topologies.

Constructor Summary

Constructors

Constructor and Description
HeronSubmitter()

Method Summary

Methods

Modifier and Type	Method and Description
static java.lang.String	submitJar(Config config, java.lang.String localJar) Submits a topology to run on the cluster.
static void	submitTopology(java.lang.String name, Config heronConfig, HeronTopology topology) Submits a topology to run on the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

HeronSubmitter

public HeronSubmitter()

Method Detail

submitTopology

public static void submitTopology(java.lang.String name,
                  Config heronConfig,
                  HeronTopology topology)
                           throws AlreadyAliveException,
                                  InvalidTopologyException

Submits a topology to run on the cluster. A topology runs forever or until explicitly killed.

Parameters:

name - the name of the topology.

heronConfig - the topology-specific configuration. See Config.

topology - the processing to execute.

Throws:

AlreadyAliveException - if a topology with this name is already running

InvalidTopologyException - if an invalid topology was submitted

submitJar

public static java.lang.String submitJar(Config config,
                         java.lang.String localJar)

Submits a topology to run on the cluster. A topology runs forever or until explicitly killed.