Package org.apache.storm.trident
Class TridentState
java.lang.Object
org.apache.storm.trident.TridentState
- All Implemented Interfaces:
ResourceDeclarer<TridentState>
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionaddSharedMemory
(SharedMemory request) Add in request for shared memory that this component will use.parallelismHint
(int parallelism) setCPULoad
(Number load) Set the amount of CPU load for this component.setMemoryLoad
(Number onHeap) Set the amount of on heap memory for this component.setMemoryLoad
(Number onHeap, Number offHeap) Set the amount of memory for this component on and off heap.
-
Constructor Details
-
TridentState
-
-
Method Details
-
newValuesStream
-
parallelismHint
-
setCPULoad
Description copied from interface:ResourceDeclarer
Set the amount of CPU load for this component.- Specified by:
setCPULoad
in interfaceResourceDeclarer<TridentState>
- Parameters:
load
- the amount of CPU- Returns:
- this for chaining
-
setMemoryLoad
Description copied from interface:ResourceDeclarer
Set the amount of on heap memory for this component.- Specified by:
setMemoryLoad
in interfaceResourceDeclarer<TridentState>
- Parameters:
onHeap
- the amount of on heap memory- Returns:
- this for chaining
-
setMemoryLoad
Description copied from interface:ResourceDeclarer
Set the amount of memory for this component on and off heap.- Specified by:
setMemoryLoad
in interfaceResourceDeclarer<TridentState>
- Parameters:
onHeap
- the amount of on heap memoryoffHeap
- the amount of off heap memory- Returns:
- this for chaining
-