Constructor and Description |
---|
JoinProcessor(boolean leftJoinProcessor,
boolean preJoinProcessor,
boolean outerJoinProcessor,
int matchingStreamIndex,
String siddhiAppName,
String queryName) |
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
getCompiledCondition() |
CompiledSelection |
getCompiledSelection() |
Processor |
getNextProcessor()
Get next processor element in the processor chain.
|
StateEvent |
joinEventBuilder(StreamEvent leftStream,
StreamEvent rightStream,
ComplexEvent.Type type)
Join the given two event streams.
|
void |
process(ComplexEventChunk complexEventChunk)
Process the handed StreamEvent.
|
void |
process(List<ComplexEventChunk> complexEventChunks)
Process the handed StreamEvent
|
void |
setCompiledCondition(CompiledCondition compiledCondition) |
void |
setCompiledSelection(CompiledSelection compiledSelection) |
void |
setExpectedOutputAttributes(List<io.siddhi.query.api.definition.Attribute> expectedOutputAttributes) |
void |
setFindableProcessor(FindableProcessor findableProcessor) |
void |
setNextProcessor(Processor processor)
Set next processor element in processor chain.
|
void |
setStateEventFactory(StateEventFactory stateEventFactory) |
void |
setToLast(Processor processor)
Set as the last element of the processor chain.
|
void |
setTrigger(boolean trigger) |
public void process(ComplexEventChunk complexEventChunk)
public void process(List<ComplexEventChunk> complexEventChunks)
Processor
public void setExpectedOutputAttributes(List<io.siddhi.query.api.definition.Attribute> expectedOutputAttributes)
public Processor getNextProcessor()
getNextProcessor
in interface Processor
public void setNextProcessor(Processor processor)
setNextProcessor
in interface Processor
processor
- Processor to be set as next element of processor chainpublic void setToLast(Processor processor)
public void setFindableProcessor(FindableProcessor findableProcessor)
public CompiledCondition getCompiledCondition()
public void setCompiledCondition(CompiledCondition compiledCondition)
public void setTrigger(boolean trigger)
public void setStateEventFactory(StateEventFactory stateEventFactory)
public CompiledSelection getCompiledSelection()
public void setCompiledSelection(CompiledSelection compiledSelection)
public StateEvent joinEventBuilder(StreamEvent leftStream, StreamEvent rightStream, ComplexEvent.Type type)
leftStream
- event left streamrightStream
- event right streamtype
- complex event typeCopyright © 2021. All rights reserved.