public class SinkCallback extends StreamCallback
Event
s from Siddhi Streams using
StreamJunction
and send them to SinkMapper
s to do the mapping.Constructor and Description |
---|
SinkCallback(List<Sink> sinks,
io.siddhi.query.api.definition.AbstractDefinition outputStreamDefinition) |
Modifier and Type | Method and Description |
---|---|
void |
init(SiddhiAppContext siddhiAppContext) |
void |
receive(Event event) |
void |
receive(Event[] events) |
getStreamDefinition, getStreamId, receive, receive, receive, receiveEvents, setContext, setStreamDefinition, setStreamId, startProcessing, stopProcessing, toMap, toMap
public void init(SiddhiAppContext siddhiAppContext)
public void receive(Event event)
receive
in interface StreamJunction.Receiver
receive
in class StreamCallback
public void receive(Event[] events)
receive
in interface StreamJunction.Receiver
receive
in class StreamCallback
Copyright © 2019. All rights reserved.