Modifier and Type | Method and Description |
---|---|
Event[] |
SiddhiAppRuntime.query(io.siddhi.query.api.execution.query.StoreQuery storeQuery) |
Event[] |
SiddhiAppRuntime.query(String storeQuery) |
Modifier and Type | Method and Description |
---|---|
Event |
Event.copyFrom(ComplexEvent complexEvent) |
Event |
Event.copyFrom(Event event) |
Modifier and Type | Method and Description |
---|---|
Event |
Event.copyFrom(Event event) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
FaultStreamEventConverter.convert(Event[] events,
Exception e) |
StreamEvent |
FaultStreamEventConverter.convert(Event event,
Exception e) |
void |
ConversionStreamEventChunk.convertAndAdd(Event event) |
void |
ConversionStreamEventChunk.convertAndAssign(Event event) |
void |
ConversionStreamEventChunk.convertAndAssign(Event[] events) |
void |
ZeroStreamEventConverter.convertEvent(Event event,
StreamEvent newEvent) |
void |
SelectiveStreamEventConverter.convertEvent(Event event,
StreamEvent newEvent) |
void |
StreamEventConverter.convertEvent(Event event,
StreamEvent newEvent)
Method to construct StreamEvent form Event
|
void |
SimpleStreamEventConverter.convertEvent(Event event,
StreamEvent newEvent) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
FaultStreamEventConverter.convert(List<Event> events,
Exception e) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionStreamReceiver.receive(Event event) |
void |
PartitionStreamReceiver.receive(Event[] events) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionStreamReceiver.receive(List<Event> events) |
Modifier and Type | Method and Description |
---|---|
Event[] |
SelectStoreQueryRuntime.execute() |
Event[] |
FindStoreQueryRuntime.execute() |
Event[] |
StoreQueryRuntime.execute()
This method initiates the execution of store query.
|
Modifier and Type | Method and Description |
---|---|
void |
ProcessStreamReceiver.receive(Event event) |
void |
MultiProcessStreamReceiver.receive(Event event) |
void |
ProcessStreamReceiver.receive(Event[] events) |
void |
MultiProcessStreamReceiver.receive(Event[] events) |
Modifier and Type | Method and Description |
---|---|
void |
ProcessStreamReceiver.receive(List<Event> events) |
void |
MultiProcessStreamReceiver.receive(List<Event> events) |
Modifier and Type | Method and Description |
---|---|
abstract void |
QueryCallback.receive(long timestamp,
Event[] inEvents,
Event[] removeEvents) |
abstract void |
QueryCallback.receive(long timestamp,
Event[] inEvents,
Event[] removeEvents) |
Modifier and Type | Method and Description |
---|---|
void |
StreamJunction.Receiver.receive(Event event) |
void |
StreamJunction.Receiver.receive(Event[] events) |
void |
StreamJunction.Publisher.send(Event[] events,
int streamIndex) |
void |
StreamJunction.Publisher.send(Event event,
int streamIndex) |
void |
StreamJunction.sendEvent(Event event) |
Modifier and Type | Method and Description |
---|---|
void |
StreamJunction.Receiver.receive(List<Event> events) |
void |
StreamJunction.Publisher.send(List<Event> events,
int streamIndex) |
Modifier and Type | Method and Description |
---|---|
void |
InputHandler.send(Event event) |
void |
InputHandler.send(Event[] events) |
void |
InputDistributor.send(Event[] events,
int streamIndex) |
void |
InputProcessor.send(Event[] events,
int streamIndex) |
void |
InputEntryValve.send(Event[] events,
int streamIndex) |
void |
InputDistributor.send(Event event,
int streamIndex) |
void |
InputProcessor.send(Event event,
int streamIndex) |
void |
InputEntryValve.send(Event event,
int streamIndex) |
Modifier and Type | Method and Description |
---|---|
void |
InputDistributor.send(List<Event> events,
int streamIndex) |
void |
InputProcessor.send(List<Event> events,
int streamIndex) |
void |
InputEntryValve.send(List<Event> events,
int streamIndex) |
Modifier and Type | Method and Description |
---|---|
void |
InputEventHandler.sendEvent(Event event) |
abstract void |
SourceHandler.sendEvent(Event[] events,
String[] transportSyncProperties,
S state,
InputHandler inputHandler) |
void |
SourceHandler.sendEvent(Event event,
String[] transportSyncProperties) |
void |
PassThroughSourceHandler.sendEvent(Event event,
String[] transportSyncProperties) |
void |
InputEventHandlerCallback.sendEvent(Event event,
String[] transportSyncProperties) |
abstract void |
SourceHandler.sendEvent(Event event,
String[] transportSyncProperties,
S state,
InputHandler inputHandler) |
void |
InputEventHandler.sendEvents(Event[] events) |
void |
SourceHandler.sendEvents(Event[] events,
String[] transportSyncProperties) |
void |
PassThroughSourceHandler.sendEvents(Event[] events,
String[] transportSyncProperties) |
void |
InputEventHandlerCallback.sendEvents(Event[] events,
String[] transportSyncProperties) |
Modifier and Type | Method and Description |
---|---|
void |
StreamCallback.receive(Event event) |
abstract void |
StreamCallback.receive(Event[] events) |
void |
StreamCallback.receiveEvents(Event[] events) |
Map<String,Object> |
StreamCallback.toMap(Event event) |
Map<String,Object>[] |
StreamCallback.toMap(Event[] events) |
Modifier and Type | Method and Description |
---|---|
void |
StreamCallback.receive(List<Event> events) |
Modifier and Type | Method and Description |
---|---|
String |
PartitionedGroupDeterminer.decideGroup(Event event)
Deciding the group of a given event and returning a unique identifier to identify a group.
|
String |
OutputGroupDeterminer.decideGroup(Event event)
Deciding the group of a given event and returning a unique identifier to identify the group.
|
String |
DynamicOptionGroupDeterminer.decideGroup(Event event)
Deciding the group of a given event and returning a unique identifier to identify the group.
|
void |
SinkHandler.handle(Event event) |
void |
SinkHandler.handle(Event[] events) |
abstract void |
SinkHandler.handle(Event[] events,
SinkHandlerCallback sinkHandlerCallback,
S state) |
abstract void |
SinkHandler.handle(Event event,
SinkHandlerCallback sinkHandlerCallback,
S state) |
void |
SinkHandlerCallback.mapAndSend(Event event) |
void |
SinkHandlerCallback.mapAndSend(Event[] events) |
abstract void |
SinkMapper.mapAndSend(Event[] events,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the events and send them to
SinkListener for publishing |
void |
PassThroughSinkMapper.mapAndSend(Event[] events,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener) |
abstract void |
SinkMapper.mapAndSend(Event event,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the event and send it to
SinkListener for publishing |
void |
PassThroughSinkMapper.mapAndSend(Event event,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener) |
void |
SinkCallback.receive(Event event) |
void |
SinkCallback.receive(Event[] events) |
Modifier and Type | Method and Description |
---|---|
static Event[] |
StoreQueryRuntimeUtil.executeSelector(StreamEvent streamEvents,
QuerySelector selector,
StateEventFactory stateEventFactory,
MetaStreamEvent.EventType eventType) |
Modifier and Type | Method and Description |
---|---|
static void |
EventPrinter.print(Event[] events) |
static void |
EventPrinter.print(long timestamp,
Event[] inEvents,
Event[] removeEvents) |
static void |
EventPrinter.print(long timestamp,
Event[] inEvents,
Event[] removeEvents) |
Modifier and Type | Method and Description |
---|---|
Event |
EventExchangeHolder.getEvent() |
Modifier and Type | Method and Description |
---|---|
Event |
DynamicOptions.getEvent() |
Modifier and Type | Method and Description |
---|---|
Object |
TemplateBuilder.build(Event event) |
static Map<String,Object> |
TemplateBuilder.convert(Event event,
Map<String,TemplateBuilder> converterMap) |
static Object[] |
TemplateBuilder.convert(Event event,
TemplateBuilder[] templateBuilders) |
String |
Option.getValue(Event event) |
Constructor and Description |
---|
DynamicOptions(Event event) |
Copyright © 2019. All rights reserved.