S
- current state for the Sink Holderpublic abstract class SinkHandler<S extends State> extends Object
SinkMapper
.
It will do optional processing to the events before sending the events to the desired mapperConstructor and Description |
---|
SinkHandler() |
Modifier and Type | Method and Description |
---|---|
String |
getId() |
void |
handle(Event event) |
void |
handle(Event[] events) |
abstract void |
handle(Event[] events,
SinkHandlerCallback sinkHandlerCallback,
S state) |
abstract void |
handle(Event event,
SinkHandlerCallback sinkHandlerCallback,
S state) |
abstract StateFactory<S> |
init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
SinkHandlerCallback sinkHandlerCallback) |
public abstract StateFactory<S> init(io.siddhi.query.api.definition.StreamDefinition streamDefinition, SinkHandlerCallback sinkHandlerCallback)
public void handle(Event event)
public void handle(Event[] events)
public abstract void handle(Event event, SinkHandlerCallback sinkHandlerCallback, S state)
public abstract void handle(Event[] events, SinkHandlerCallback sinkHandlerCallback, S state)
public String getId()
Copyright © 2021. All rights reserved.