S
- current state of the RateLimiterpublic abstract class SnapshotOutputRateLimiter<S extends State> extends Object implements Schedulable
Scheduler
to handle periodic snapshot rate
limiting.Modifier and Type | Field and Description |
---|---|
protected LockWrapper |
lockWrapper |
protected SiddhiQueryContext |
siddhiQueryContext |
protected StateEventCloner |
stateEventCloner |
protected StateHolder<S> |
stateHolder |
protected StreamEventCloner |
streamEventCloner |
Modifier | Constructor and Description |
---|---|
protected |
SnapshotOutputRateLimiter(WrappedSnapshotOutputRateLimiter wrappedSnapshotOutputRateLimiter,
SiddhiQueryContext siddhiQueryContext,
boolean groupBy) |
Modifier and Type | Method and Description |
---|---|
protected ComplexEvent |
cloneComplexEvent(ComplexEvent complexEvent)
Clones a given complex event.
|
protected abstract StateFactory<S> |
init() |
abstract void |
partitionCreated() |
abstract void |
process(ComplexEventChunk complexEventChunk) |
protected void |
sendToCallBacks(List<ComplexEventChunk> outputEventChunks) |
void |
setQueryLock(LockWrapper lockWrapper) |
void |
setStateEventCloner(StateEventCloner stateEventCloner) |
void |
setStreamEventCloner(StreamEventCloner streamEventCloner) |
protected final StateHolder<S extends State> stateHolder
protected StreamEventCloner streamEventCloner
protected StateEventCloner stateEventCloner
protected SiddhiQueryContext siddhiQueryContext
protected LockWrapper lockWrapper
protected SnapshotOutputRateLimiter(WrappedSnapshotOutputRateLimiter wrappedSnapshotOutputRateLimiter, SiddhiQueryContext siddhiQueryContext, boolean groupBy)
protected abstract StateFactory<S> init()
public abstract void process(ComplexEventChunk complexEventChunk)
process
in interface Schedulable
public void setStreamEventCloner(StreamEventCloner streamEventCloner)
public void setStateEventCloner(StateEventCloner stateEventCloner)
protected void sendToCallBacks(List<ComplexEventChunk> outputEventChunks)
protected ComplexEvent cloneComplexEvent(ComplexEvent complexEvent)
complexEvent
- Complex event to be clonedpublic abstract void partitionCreated()
public void setQueryLock(LockWrapper lockWrapper)
Copyright © 2019. All rights reserved.