public class InputEntryValve extends Object implements InputProcessor
InputProcessor
which inject the event to the next input processor through a valve.Constructor and Description |
---|
InputEntryValve(SiddhiAppContext siddhiAppContext,
InputProcessor inputProcessor) |
public InputEntryValve(SiddhiAppContext siddhiAppContext, InputProcessor inputProcessor)
public void send(Event event, int streamIndex)
send
in interface InputProcessor
public void send(Event[] events, int streamIndex)
send
in interface InputProcessor
public void send(List<Event> events, int streamIndex)
send
in interface InputProcessor
public void send(long timestamp, Object[] data, int streamIndex)
send
in interface InputProcessor
Copyright © 2019. All rights reserved.