Package org.apache.storm.trident.planner

Class PartitionNode

java.lang.Object

org.apache.storm.trident.operation.DefaultResourceDeclarer<Node>

org.apache.storm.trident.planner.Node

org.apache.storm.trident.planner.PartitionNode

All Implemented Interfaces:

Serializable, ResourceDeclarer<Node>, ITridentResource

public class PartitionNode
extends Node

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
Grouping	thriftGrouping

Fields inherited from class org.apache.storm.trident.planner.Node

allOutputFields, creationIndex, name, parallelismHint, stateInfo, streamId

Constructor Summary

Constructors

Constructor	Description
PartitionNode(String streamId, String name, Fields allOutputFields, Grouping grouping)

Method Summary

Methods inherited from class org.apache.storm.trident.planner.Node

equals, hashCode, shortString, toString

Methods inherited from class org.apache.storm.trident.operation.DefaultResourceDeclarer

addSharedMemory, getResources, getSharedMemory, setCPULoad, setMemoryLoad, setMemoryLoad

Methods inherited from class java.lang.Object

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

Field Details

thriftGrouping

public transient Grouping thriftGrouping

Constructor Details

PartitionNode

public PartitionNode(String streamId,
 String name,
 Fields allOutputFields,
 Grouping grouping)