public class MetaStreamEvent extends Object implements MetaComplexEvent
Modifier and Type | Class and Description |
---|---|
static class |
MetaStreamEvent.EventType
Type of Meta Events
|
Constructor and Description |
---|
MetaStreamEvent() |
Modifier and Type | Method and Description |
---|---|
int |
addData(io.siddhi.query.api.definition.Attribute attribute)
Universal method to add data to MetaStream event.
|
void |
addInputDefinition(io.siddhi.query.api.definition.AbstractDefinition inputDefinition) |
void |
addOutputData(io.siddhi.query.api.definition.Attribute attribute) |
void |
addOutputDataAllowingDuplicate(io.siddhi.query.api.definition.Attribute attribute) |
MetaStreamEvent |
clone() |
List<io.siddhi.query.api.definition.Attribute> |
getBeforeWindowData() |
MetaStreamEvent.EventType |
getEventType() |
List<io.siddhi.query.api.definition.AbstractDefinition> |
getInputDefinitions() |
String |
getInputReferenceId() |
io.siddhi.query.api.definition.AbstractDefinition |
getLastInputDefinition() |
List<io.siddhi.query.api.definition.Attribute> |
getOnAfterWindowData() |
List<io.siddhi.query.api.definition.Attribute> |
getOutputData() |
io.siddhi.query.api.definition.StreamDefinition |
getOutputStreamDefinition() |
void |
initializeAfterWindowData() |
void |
setEventType(MetaStreamEvent.EventType eventType) |
void |
setInputReferenceId(String inputReferenceId) |
void |
setOutputDefinition(io.siddhi.query.api.definition.StreamDefinition streamDefinition) |
public List<io.siddhi.query.api.definition.Attribute> getBeforeWindowData()
public List<io.siddhi.query.api.definition.Attribute> getOnAfterWindowData()
public List<io.siddhi.query.api.definition.Attribute> getOutputData()
public void initializeAfterWindowData()
public int addData(io.siddhi.query.api.definition.Attribute attribute)
attribute
- attributepublic void addOutputData(io.siddhi.query.api.definition.Attribute attribute)
public void addOutputDataAllowingDuplicate(io.siddhi.query.api.definition.Attribute attribute)
public List<io.siddhi.query.api.definition.AbstractDefinition> getInputDefinitions()
public void addInputDefinition(io.siddhi.query.api.definition.AbstractDefinition inputDefinition)
public String getInputReferenceId()
public void setInputReferenceId(String inputReferenceId)
public void setOutputDefinition(io.siddhi.query.api.definition.StreamDefinition streamDefinition)
setOutputDefinition
in interface MetaComplexEvent
public io.siddhi.query.api.definition.StreamDefinition getOutputStreamDefinition()
getOutputStreamDefinition
in interface MetaComplexEvent
public MetaStreamEvent.EventType getEventType()
public void setEventType(MetaStreamEvent.EventType eventType)
public io.siddhi.query.api.definition.AbstractDefinition getLastInputDefinition()
public MetaStreamEvent clone()
Copyright © 2019. All rights reserved.