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 java.util.Map<EPStatementAgentInstanceHandle,java.util.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 java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> |
NamedWindowUtil.createConsumerMap(boolean isPrioritized) |
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> |
NamedWindowTailView.getConsumersNonContext() |
java.util.LinkedHashMap<NamedWindowConsumerView,NamedWindowDeltaData> |
NamedWindowDispatchServiceImpl.getDeltaPerConsumer(java.lang.Object perStmtObj,
EPStatementAgentInstanceHandle handle) |
java.util.Map<EPStatementAgentInstanceHandle,java.util.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) |
Modifier and Type | Method and Description |
---|---|
void |
NamedWindowDispatchServiceImpl.addDispatch(NamedWindowConsumerLatchFactory latchFactory,
NamedWindowDeltaData delta,
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumers) |
void |
NamedWindowDispatchService.addDispatch(NamedWindowConsumerLatchFactory latchFactory,
NamedWindowDeltaData delta,
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumers)
For use to add a result of a named window that must be dispatched to consuming views.
|
void |
NamedWindowTailView.addDispatches(NamedWindowConsumerLatchFactory latchFactory,
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumersInContext,
NamedWindowDeltaData delta,
AgentInstanceContext agentInstanceContext) |
NamedWindowConsumerLatch |
NamedWindowConsumerLatchFactory.newLatch(NamedWindowDeltaData delta,
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumers)
Returns a new latch.
|
Constructor and Description |
---|
NamedWindowConsumerLatch(NamedWindowDeltaData deltaData,
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> dispatchTo) |
NamedWindowConsumerLatchNone(NamedWindowDeltaData deltaData,
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> dispatchTo) |
NamedWindowConsumerLatchSpin(NamedWindowDeltaData deltaData,
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> dispatchTo,
NamedWindowConsumerLatchFactory factory,
NamedWindowConsumerLatchSpin earlier) |
NamedWindowConsumerLatchWait(NamedWindowDeltaData deltaData,
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> dispatchTo,
NamedWindowConsumerLatchFactory factory,
NamedWindowConsumerLatchWait earlier) |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.qNamedWindowCPMulti(java.lang.String engineURI,
java.util.Map<NamedWindowConsumerView,NamedWindowDeltaData> deltaPerConsumer,
EPStatementAgentInstanceHandle handle,
long time) |
void |
Instrumentation.qNamedWindowCPMulti(java.lang.String engineURI,
java.util.Map<NamedWindowConsumerView,NamedWindowDeltaData> deltaPerConsumer,
EPStatementAgentInstanceHandle handle,
long time) |
void |
InstrumentationDefault.qNamedWindowCPSingle(java.lang.String engineURI,
java.util.List<NamedWindowConsumerView> value,
EventBean[] newData,
EventBean[] oldData,
EPStatementAgentInstanceHandle handle,
long time) |
void |
Instrumentation.qNamedWindowCPSingle(java.lang.String engineURI,
java.util.List<NamedWindowConsumerView> value,
EventBean[] newData,
EventBean[] oldData,
EPStatementAgentInstanceHandle handle,
long time) |