Constructor and Description |
---|
StateEventCloner(MetaStateEvent metaStateEvent,
StateEventFactory stateEventFactory) |
Modifier and Type | Method and Description |
---|---|
void |
StoreQueryRuntime.setStateEventFactory(StateEventFactory stateEventFactory)
This method sets a state event pool for store query runtime.
|
Modifier and Type | Method and Description |
---|---|
void |
JoinProcessor.setStateEventFactory(StateEventFactory stateEventFactory) |
Modifier and Type | Field and Description |
---|---|
protected StateEventFactory |
StreamPreStateProcessor.stateEventFactory |
Modifier and Type | Method and Description |
---|---|
void |
StreamPreStateProcessor.setStateEventFactory(StateEventFactory stateEventFactory) |
Modifier and Type | Method and Description |
---|---|
protected ComplexEventChunk<StateEvent> |
OutputCallback.constructMatchingStateEventChunk(ComplexEventChunk matchingComplexEventChunk,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
int matchingStreamIndex,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter) |
Constructor and Description |
---|
DeleteTableCallback(Table table,
CompiledCondition compiledCondition,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
UpdateOrInsertTableCallback(Table table,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
UpdateTableCallback(Table table,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
Modifier and Type | Method and Description |
---|---|
static Event[] |
StoreQueryRuntimeUtil.executeSelector(StreamEvent streamEvents,
QuerySelector selector,
StateEventFactory stateEventFactory,
MetaStreamEvent.EventType eventType) |
static StreamEvent |
StoreQueryRuntimeUtil.executeSelectorAndReturnStreamEvent(StreamEvent streamEvents,
QuerySelector selector,
StateEventFactory stateEventFactory,
MetaStreamEvent.EventType eventType) |
Copyright © 2019. All rights reserved.