storm.trident.planner
Class ProcessorNode

java.lang.Object
  storm.trident.planner.Node
      storm.trident.planner.ProcessorNode

All Implemented Interfaces:

java.io.Serializable

public class ProcessorNode
extends Node

See Also:

Serialized Form

Field Summary

boolean	committer
TridentProcessor	processor
Fields	selfOutFields

Fields inherited from class storm.trident.planner.Node

allOutputFields, creationIndex, parallelismHint, stateInfo, streamId

Constructor Summary

ProcessorNode(java.lang.String streamId, Fields allOutputFields, Fields selfOutFields, TridentProcessor processor)

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

committer

public boolean committer

processor

public TridentProcessor processor

selfOutFields

public Fields selfOutFields

Constructor Detail

ProcessorNode

public ProcessorNode(java.lang.String streamId,
                     Fields allOutputFields,
                     Fields selfOutFields,
                     TridentProcessor processor)