storm.trident
Class TridentState

java.lang.Object
  storm.trident.TridentState

public class TridentState
extends java.lang.Object

Constructor Summary

protected

TridentState(TridentTopology topology, Node node)

Method Summary

Stream	newValuesStream()
TridentState	parallelismHint(int parallelism)

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentState

protected TridentState(TridentTopology topology,
                       Node node)

Method Detail

newValuesStream

public Stream newValuesStream()

parallelismHint

public TridentState parallelismHint(int parallelism)