Package | Description |
---|---|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
Modifier and Type | Field and Description |
---|---|
protected Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> |
NamedWindowTailView.consumersNonContext |
Modifier and Type | Method and Description |
---|---|
NamedWindowConsumerView |
NamedWindowTailView.addConsumer(NamedWindowConsumerDesc consumerDesc) |
NamedWindowConsumerView |
NamedWindowTailViewInstance.addConsumer(NamedWindowConsumerDesc consumerDesc,
boolean isSubselect) |
NamedWindowConsumerView |
NamedWindowProcessor.addConsumer(NamedWindowConsumerDesc consumerDesc,
boolean isSubselect) |
Modifier and Type | Method and Description |
---|---|
protected static Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> |
NamedWindowUtil.createConsumerMap(boolean isPrioritized) |
Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> |
NamedWindowTailView.getConsumersNonContext() |
LinkedHashMap<NamedWindowConsumerView,NamedWindowDeltaData> |
NamedWindowDispatchServiceImpl.getDeltaPerConsumer(Object perStmtObj,
EPStatementAgentInstanceHandle handle) |
Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> |
NamedWindowConsumerLatch.getDispatchTo() |
Modifier and Type | Method and Description |
---|---|
void |
NamedWindowTailViewInstance.removeConsumer(NamedWindowConsumerView namedWindowConsumerView)
Called by the consumer view to indicate it was stopped or destroyed, such that the
consumer can be deregistered and further dispatches disregard this consumer.
|
void |
NamedWindowTailView.removeConsumer(NamedWindowConsumerView namedWindowConsumerView)
Called by the consumer view to indicate it was stopped or destroyed, such that the
consumer can be deregistered and further dispatches disregard this consumer.
|
void |
NamedWindowConsumerCallback.stopped(NamedWindowConsumerView namedWindowConsumerView) |
Constructor and Description |
---|
NamedWindowConsumerLatch(NamedWindowDeltaData deltaData,
Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> dispatchTo) |
NamedWindowConsumerLatchNone(NamedWindowDeltaData deltaData,
Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> dispatchTo) |
NamedWindowConsumerLatchSpin(NamedWindowDeltaData deltaData,
Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> dispatchTo,
NamedWindowConsumerLatchFactory factory,
NamedWindowConsumerLatchSpin earlier) |
NamedWindowConsumerLatchWait(NamedWindowDeltaData deltaData,
Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> dispatchTo,
NamedWindowConsumerLatchFactory factory,
NamedWindowConsumerLatchWait earlier) |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.qNamedWindowCPMulti(String engineURI,
Map<NamedWindowConsumerView,NamedWindowDeltaData> deltaPerConsumer,
EPStatementAgentInstanceHandle handle,
long time) |
void |
Instrumentation.qNamedWindowCPMulti(String engineURI,
Map<NamedWindowConsumerView,NamedWindowDeltaData> deltaPerConsumer,
EPStatementAgentInstanceHandle handle,
long time) |
void |
InstrumentationDefault.qNamedWindowCPSingle(String engineURI,
List<NamedWindowConsumerView> value,
EventBean[] newData,
EventBean[] oldData,
EPStatementAgentInstanceHandle handle,
long time) |
void |
Instrumentation.qNamedWindowCPSingle(String engineURI,
List<NamedWindowConsumerView> value,
EventBean[] newData,
EventBean[] oldData,
EPStatementAgentInstanceHandle handle,
long time) |