storm.trident.planner
Class PartitionNode

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

All Implemented Interfaces:

java.io.Serializable

public class PartitionNode
extends Node

See Also:

Serialized Form

Field Summary

Grouping

thriftGrouping

Fields inherited from class storm.trident.planner.Node

allOutputFields, creationIndex, parallelismHint, stateInfo, streamId

Constructor Summary

PartitionNode(java.lang.String streamId, Fields allOutputFields, Grouping grouping)

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

thriftGrouping

public transient Grouping thriftGrouping

Constructor Detail

PartitionNode

public PartitionNode(java.lang.String streamId,
                     Fields allOutputFields,
                     Grouping grouping)