Package | Description |
---|---|
com.espertech.esper.core.thread |
This package contains classes to advanced threading options.
|
Modifier and Type | Method and Description |
---|---|
void |
ThreadingServiceImpl.initThreading(EPServicesContext services,
EPRuntimeImpl runtime) |
void |
ThreadingService.initThreading(EPServicesContext services,
EPRuntimeImpl runtime)
Initialize thread pools.
|
Constructor and Description |
---|
InboundUnitSendAvro(java.lang.Object genericRecordDotData,
java.lang.String eventTypeName,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor.
|
InboundUnitSendDOM(org.w3c.dom.Node theEvent,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor.
|
InboundUnitSendEvent(java.lang.Object theEvent,
EPRuntimeImpl runtime)
Ctor.
|
InboundUnitSendMap(java.util.Map map,
java.lang.String eventTypeName,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor.
|
InboundUnitSendObjectArray(java.lang.Object[] properties,
java.lang.String eventTypeName,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor.
|
RouteUnitMultiple(EPRuntimeImpl epRuntime,
java.lang.Object callbackList,
EventBean theEvent,
EPStatementAgentInstanceHandle handle,
long filterVersion)
Ctor.
|
RouteUnitSingle(EPRuntimeImpl epRuntime,
EPStatementHandleCallback handleCallback,
EventBean theEvent,
long filterVersion)
Ctor.
|
TimerUnitMultiple(EPServicesContext services,
EPRuntimeImpl runtime,
EPStatementAgentInstanceHandle handle,
java.lang.Object callbackObject)
Ctor.
|
TimerUnitSingle(EPServicesContext services,
EPRuntimeImpl runtime,
EPStatementHandleCallback handleCallback)
Ctor.
|