org.apache.storm.trident

Class TridentState

java.lang.Object

org.apache.storm.trident.TridentState

All Implemented Interfaces:

ResourceDeclarer<TridentState>

public class TridentState
extends Object
implements ResourceDeclarer<TridentState>

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)
TridentState	setCPULoad(Number load)
TridentState	setMemoryLoad(Number onHeap)
TridentState	setMemoryLoad(Number onHeap, Number offHeap)

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)

setCPULoad

public TridentState setCPULoad(Number load)

Specified by:

setCPULoad in interface ResourceDeclarer<TridentState>

setMemoryLoad

public TridentState setMemoryLoad(Number onHeap)

Specified by:

setMemoryLoad in interface ResourceDeclarer<TridentState>

setMemoryLoad

public TridentState setMemoryLoad(Number onHeap,
                                  Number offHeap)

Specified by:

setMemoryLoad in interface ResourceDeclarer<TridentState>