public class OutputParser extends Object
OutputCallback
Constructor and Description |
---|
OutputParser() |
Modifier and Type | Method and Description |
---|---|
static OutputCallback |
constructOutputCallback(io.siddhi.query.api.execution.query.output.stream.OutputStream outStream,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
Map<String,Table> tableMap,
Map<String,Window> eventWindowMap,
boolean convertToStreamEvent,
SiddhiQueryContext siddhiQueryContext) |
static OutputCallback |
constructOutputCallback(io.siddhi.query.api.execution.query.output.stream.OutputStream outStream,
String key,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
SiddhiQueryContext siddhiQueryContext) |
static OutputRateLimiter |
constructOutputRateLimiter(String id,
io.siddhi.query.api.execution.query.output.ratelimit.OutputRate outputRate,
boolean isGroupBy,
boolean isWindow,
SiddhiQueryContext siddhiQueryContext) |
public static OutputCallback constructOutputCallback(io.siddhi.query.api.execution.query.output.stream.OutputStream outStream, io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition, Map<String,Table> tableMap, Map<String,Window> eventWindowMap, boolean convertToStreamEvent, SiddhiQueryContext siddhiQueryContext)
public static OutputCallback constructOutputCallback(io.siddhi.query.api.execution.query.output.stream.OutputStream outStream, String key, ConcurrentMap<String,StreamJunction> streamJunctionMap, io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition, SiddhiQueryContext siddhiQueryContext)
public static OutputRateLimiter constructOutputRateLimiter(String id, io.siddhi.query.api.execution.query.output.ratelimit.OutputRate outputRate, boolean isGroupBy, boolean isWindow, SiddhiQueryContext siddhiQueryContext)
Copyright © 2021. All rights reserved.