storm.trident.planner

Class SpoutNode

java.lang.Object

storm.trident.planner.Node

storm.trident.planner.SpoutNode

All Implemented Interfaces:

Serializable

public class SpoutNode
extends Node

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SpoutNode.SpoutType

Field Summary

Fields

Modifier and Type	Field and Description
Object	spout
String	txId
SpoutNode.SpoutType	type

Fields inherited from class storm.trident.planner.Node

allOutputFields, creationIndex, name, parallelismHint, stateInfo, streamId

Constructor Summary

Constructors

Constructor and Description
SpoutNode(String streamId, Fields allOutputFields, String txid, Object spout, SpoutNode.SpoutType type)

Method Summary

Methods inherited from class storm.trident.planner.Node

equals, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

spout

public Object spout

txId

public String txId

type

public SpoutNode.SpoutType type

Constructor Detail

SpoutNode

public SpoutNode(String streamId,
                 Fields allOutputFields,
                 String txid,
                 Object spout,
                 SpoutNode.SpoutType type)