com.twitter.heron.integration_test.core

Class TestTopologyBuilder

java.lang.Object

com.twitter.heron.api.topology.TopologyBuilder

com.twitter.heron.integration_test.core.TestTopologyBuilder

public class TestTopologyBuilder
extends TopologyBuilder

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestTopologyBuilder.SpoutWrapperType

Constructor Summary

Constructors

Constructor and Description
TestTopologyBuilder(java.lang.String outputLocation)
TestTopologyBuilder(java.lang.String outputLocation, java.lang.String stateLocation, java.lang.String stateUpdateToken, TestTopologyBuilder.SpoutWrapperType spoutWrapperType)

Method Summary

Modifier and Type	Method and Description
protected void	addAllGrouping(java.lang.String child, java.lang.String parent, java.lang.String streamId) Given a child component and its upstream component, add the allGrouping between them with given streamId
HeronTopology	createTopology()
BoltDeclarer	setBolt(java.lang.String id, IRichBolt bolt, java.lang.Number parallelismHint) Define a new bolt in this topology with the specified amount of parallelism.
SpoutDeclarer	setSpout(java.lang.String id, IRichSpout spout, java.lang.Number parallelismHint) Define a new spout in this topology with the specified parallelism.
SpoutDeclarer	setSpout(java.lang.String id, IRichSpout spout, java.lang.Number parallelismHint, int maxExecutionCount)
void	setTerminalBoltClass(java.lang.String terminalBoltClass)

Methods inherited from class com.twitter.heron.api.topology.TopologyBuilder

setBolt, setBolt, setBolt, setSpout

Methods inherited from class java.lang.Object

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

Constructor Detail

TestTopologyBuilder

public TestTopologyBuilder(java.lang.String outputLocation)

TestTopologyBuilder

public TestTopologyBuilder(java.lang.String outputLocation,
                           java.lang.String stateLocation,
                           java.lang.String stateUpdateToken,
                           TestTopologyBuilder.SpoutWrapperType spoutWrapperType)

Method Detail

setBolt

public BoltDeclarer setBolt(java.lang.String id,
                            IRichBolt bolt,
                            java.lang.Number parallelismHint)

Description copied from class: TopologyBuilder

Define a new bolt in this topology with the specified amount of parallelism.

Overrides:

setBolt in class TopologyBuilder

Parameters:

id - the id of this component. This id is referenced by other components that want to consume this bolt's outputs.

bolt - the bolt

parallelismHint - the number of tasks that should be assigned to execute this bolt. Each task will run on a thread in a process somewhere around the cluster.

Returns:

use the returned object to declare the inputs to this component

setSpout

public SpoutDeclarer setSpout(java.lang.String id,
                              IRichSpout spout,
                              java.lang.Number parallelismHint)

Description copied from class: TopologyBuilder

Define a new spout in this topology with the specified parallelism. If the spout declares itself as non-distributed, the parallelismHint will be ignored and only one task will be allocated to this component.

Overrides:

setSpout in class TopologyBuilder

Parameters:

id - the id of this component. This id is referenced by other components that want to consume this spout's outputs.

spout - the spout

parallelismHint - the number of tasks that should be assigned to execute this spout. Each task will run on a thread in a process somwehere around the cluster.

setSpout

public SpoutDeclarer setSpout(java.lang.String id,
                              IRichSpout spout,
                              java.lang.Number parallelismHint,
                              int maxExecutionCount)

setTerminalBoltClass

public void setTerminalBoltClass(java.lang.String terminalBoltClass)

createTopology

public HeronTopology createTopology()

Overrides:

createTopology in class TopologyBuilder

addAllGrouping

protected void addAllGrouping(java.lang.String child,
                              java.lang.String parent,
                              java.lang.String streamId)

Given a child component and its upstream component, add the allGrouping between them with given streamId

Parameters:

child - the child component id

parent - the upstream component id

streamId - the stream id