public class TridentState extends Object implements ResourceDeclarer<TridentState>
| Modifier | Constructor and Description |
|---|---|
protected |
TridentState(TridentTopology topology,
Node node) |
| Modifier and Type | Method and Description |
|---|---|
TridentState |
addSharedMemory(SharedMemory request)
Add in request for shared memory that this component will use.
|
Stream |
newValuesStream() |
TridentState |
parallelismHint(int parallelism) |
TridentState |
setCPULoad(Number load)
Set the amount of CPU load for this component.
|
TridentState |
setMemoryLoad(Number onHeap)
Set the amount of on heap memory for this component.
|
TridentState |
setMemoryLoad(Number onHeap,
Number offHeap)
Set the amount of memory for this component on and off heap.
|
protected TridentState(TridentTopology topology, Node node)
public Stream newValuesStream()
public TridentState parallelismHint(int parallelism)
public TridentState setCPULoad(Number load)
ResourceDeclarerSet the amount of CPU load for this component.
setCPULoad in interface ResourceDeclarer<TridentState>load - the amount of CPUpublic TridentState setMemoryLoad(Number onHeap)
ResourceDeclarerSet the amount of on heap memory for this component.
setMemoryLoad in interface ResourceDeclarer<TridentState>onHeap - the amount of on heap memorypublic TridentState setMemoryLoad(Number onHeap, Number offHeap)
ResourceDeclarerSet the amount of memory for this component on and off heap.
setMemoryLoad in interface ResourceDeclarer<TridentState>onHeap - the amount of on heap memoryoffHeap - the amount of off heap memorypublic TridentState addSharedMemory(SharedMemory request)
ResourceDeclarerAdd in request for shared memory that this component will use. See SharedOnHeap, SharedOffHeapWithinNode, and SharedOffHeapWithinWorker for convenient ways to create shared memory requests.
addSharedMemory in interface ResourceDeclarer<TridentState>request - the shared memory request for this componentCopyright © 2021 The Apache Software Foundation. All rights reserved.