Modifier and Type | Method and Description |
---|---|
void |
SiddhiDebugger.checkBreakPoint(String queryName,
SiddhiDebugger.QueryTerminal queryTerminal,
ComplexEvent complexEvent)
Check for active breakpoint at the given endpoint and if there is an active checkpoint, block the thread and
send the event for debug callback.
|
void |
SiddhiDebuggerCallback.debugEvent(ComplexEvent event,
String queryName,
SiddhiDebugger.QueryTerminal queryTerminal,
SiddhiDebugger debugger)
Receive the events passing through the registered breakpoints.
|
Modifier and Type | Class and Description |
---|---|
class |
ComplexEventChunk<E extends ComplexEvent>
Collection used to group and manage chunk or ComplexEvents
|
Modifier and Type | Class and Description |
---|---|
class |
GroupedComplexEvent
Implementation of
ComplexEvent to hold events belonging to the same GroupBy group. |
Modifier and Type | Field and Description |
---|---|
protected E |
ComplexEventChunk.first |
protected E |
ComplexEventChunk.last |
protected E |
ComplexEventChunk.lastReturned |
protected E |
ComplexEventChunk.previousToLastReturned |
Modifier and Type | Method and Description |
---|---|
ComplexEvent |
GroupedComplexEvent.getComplexEvent() |
ComplexEvent |
GroupedComplexEvent.getNext() |
ComplexEvent |
ComplexEvent.getNext() |
Modifier and Type | Method and Description |
---|---|
Event |
Event.copyFrom(ComplexEvent complexEvent) |
void |
GroupedComplexEvent.setNext(ComplexEvent events) |
void |
ComplexEvent.setNext(ComplexEvent events) |
Constructor and Description |
---|
GroupedComplexEvent(String groupKey,
ComplexEvent complexEvent) |
Modifier and Type | Class and Description |
---|---|
class |
StateEvent
Implementation of StateEvent to be used when executing join/pattern queries
|
Modifier and Type | Method and Description |
---|---|
void |
StateEvent.setNext(ComplexEvent stateEvent) |
Modifier and Type | Method and Description |
---|---|
void |
SkipStateEventPopulator.populateStateEvent(ComplexEvent complexEvent) |
void |
SelectiveStateEventPopulator.populateStateEvent(ComplexEvent complexEvent) |
void |
StateEventPopulator.populateStateEvent(ComplexEvent complexEvent) |
Modifier and Type | Class and Description |
---|---|
class |
StreamEvent
Standard processing event inside Siddhi.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamEvent.setNext(ComplexEvent next) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
FaultStreamEventConverter.convert(ComplexEvent complexEvents,
Exception e) |
void |
ConversionStreamEventChunk.convertAndAssign(ComplexEvent complexEvent) |
void |
SimpleStreamEventConverter.convertComplexEvent(ComplexEvent complexEvent,
StreamEvent newEvent) |
void |
StreamEventConverter.convertComplexEvent(ComplexEvent complexEvent,
StreamEvent newEvent)
Method to construct(change format) new StreamEvent from StreamEvent
|
void |
ZeroStreamEventConverter.convertComplexEvent(ComplexEvent complexEvent,
StreamEvent newEvent) |
void |
SelectiveStreamEventConverter.convertComplexEvent(ComplexEvent complexEvent,
StreamEvent newEvent) |
Modifier and Type | Method and Description |
---|---|
void |
ComplexEventPopulater.populateComplexEvent(ComplexEvent complexEvent,
Object[] data) |
void |
SelectiveComplexEventPopulater.populateComplexEvent(ComplexEvent complexEvent,
Object[] data) |
Modifier and Type | Method and Description |
---|---|
Object |
VariableExpressionExecutor.execute(ComplexEvent event) |
Object |
ConstantExpressionExecutor.execute(ComplexEvent event) |
Object |
ExpressionExecutor.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
abstract Boolean |
ConditionExpressionExecutor.execute(ComplexEvent event) |
Boolean |
OrConditionExpressionExecutor.execute(ComplexEvent event) |
Boolean |
InConditionExpressionExecutor.execute(ComplexEvent event) |
Boolean |
BoolConditionExpressionExecutor.execute(ComplexEvent event) |
Boolean |
IsNullStreamConditionExpressionExecutor.execute(ComplexEvent event) |
Boolean |
NotConditionExpressionExecutor.execute(ComplexEvent event) |
Boolean |
AndConditionExpressionExecutor.execute(ComplexEvent event) |
Boolean |
IsNullConditionExpressionExecutor.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
Boolean |
CompareConditionExpressionExecutor.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
Boolean |
NotEqualCompareConditionExpressionExecutor.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
Object |
FunctionExecutor.execute(ComplexEvent event)
The main execution method which will be called upon event arrival
|
Object |
IfThenElseFunctionExecutor.execute(ComplexEvent event) |
Object |
EventTimestampFunctionExecutor.execute(ComplexEvent event) |
Object |
CurrentTimeMillisFunctionExecutor.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
Object |
AddExpressionExecutorLong.execute(ComplexEvent event) |
Object |
AddExpressionExecutorInt.execute(ComplexEvent event) |
Object |
AddExpressionExecutorFloat.execute(ComplexEvent event) |
Object |
AddExpressionExecutorDouble.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
Object |
DivideExpressionExecutorDouble.execute(ComplexEvent event) |
Object |
DivideExpressionExecutorFloat.execute(ComplexEvent event) |
Object |
DivideExpressionExecutorInt.execute(ComplexEvent event) |
Object |
DivideExpressionExecutorLong.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
Object |
ModExpressionExecutorLong.execute(ComplexEvent event) |
Object |
ModExpressionExecutorDouble.execute(ComplexEvent event) |
Object |
ModExpressionExecutorInt.execute(ComplexEvent event) |
Object |
ModExpressionExecutorFloat.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
Object |
MultiplyExpressionExecutorInt.execute(ComplexEvent event) |
Object |
MultiplyExpressionExecutorFloat.execute(ComplexEvent event) |
Object |
MultiplyExpressionExecutorDouble.execute(ComplexEvent event) |
Object |
MultiplyExpressionExecutorLong.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
Object |
SubtractExpressionExecutorFloat.execute(ComplexEvent event) |
Object |
SubtractExpressionExecutorInt.execute(ComplexEvent event) |
Object |
SubtractExpressionExecutorLong.execute(ComplexEvent event) |
Object |
SubtractExpressionExecutorDouble.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionStreamReceiver.receive(ComplexEvent complexEvent) |
Modifier and Type | Method and Description |
---|---|
String |
ValuePartitionExecutor.execute(ComplexEvent event) |
String |
PartitionExecutor.execute(ComplexEvent event) |
String |
RangePartitionExecutor.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
MultiProcessStreamReceiver.receive(ComplexEvent complexEvent) |
void |
ProcessStreamReceiver.receive(ComplexEvent complexEvents) |
Modifier and Type | Field and Description |
---|---|
protected Comparator<ComplexEvent> |
AggregationWindowedPerSnapshotOutputRateLimiter.comparator |
Modifier and Type | Method and Description |
---|---|
protected ComplexEvent |
SnapshotOutputRateLimiter.cloneComplexEvent(ComplexEvent complexEvent)
Clones a given complex event.
|
Modifier and Type | Method and Description |
---|---|
protected ComplexEvent |
SnapshotOutputRateLimiter.cloneComplexEvent(ComplexEvent complexEvent)
Clones a given complex event.
|
Modifier and Type | Class and Description |
---|---|
static class |
SessionWindowProcessor.SessionComplexEventChunk<E extends ComplexEvent>
Collection used to manage session windows.
|
Modifier and Type | Method and Description |
---|---|
void |
HopingWindowProcessor.HopingTimestampPopulator.populateComplexEvent(ComplexEvent complexEvent,
String key) |
void |
GroupingWindowProcessor.GroupingKeyPopulator.populateComplexEvent(ComplexEvent complexEvent,
String key) |
Modifier and Type | Method and Description |
---|---|
int |
OrderByEventComparator.compare(ComplexEvent complexEvent1,
ComplexEvent complexEvent2) |
String |
GroupByKeyGenerator.constructEventKey(ComplexEvent event)
generate groupBy key of a streamEvent
|
Modifier and Type | Method and Description |
---|---|
Object |
AttributeAggregatorExecutor.execute(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
AttributeProcessor.process(ComplexEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
StreamJunction.Receiver.receive(ComplexEvent complexEvent) |
void |
StreamJunction.Publisher.send(ComplexEvent complexEvent) |
void |
StreamJunction.sendEvent(ComplexEvent complexEvent) |
Modifier and Type | Method and Description |
---|---|
void |
StreamCallback.receive(ComplexEvent complexEvent) |
Modifier and Type | Class and Description |
---|---|
class |
FinderStateEvent
State Event holder used by
InConditionExpressionExecutor |
Modifier and Type | Method and Description |
---|---|
Object |
TemplateBuilder.build(ComplexEvent complexEvent) |
Copyright © 2019. All rights reserved.