storm.trident

Class TridentState

java.lang.Object

storm.trident.TridentState

public class TridentState
extends Object

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TridentState(TridentTopology topology, Node node)

Method Summary

Modifier and Type	Method and Description
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)