Package | Description |
---|---|
com.espertech.esper.client.dataflow |
Client API for data flows.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.thread |
This package contains classes to advanced threading options.
|
com.espertech.esper.dataflow.interfaces |
Data flow operator and related interface.
|
com.espertech.esper.event |
This package defines the internal event APIs.
|
com.espertech.esper.plugin |
APIs for plug-in adapter (for input-output) and plug-in event representation (event types and event objects) are in
this package.
|
Modifier and Type | Method and Description |
---|---|
EPRuntimeEventSender |
EPDataFlowInstantiationOptions.getSurrogateEventSender()
Returns the event sender /runtime to use
|
Modifier and Type | Method and Description |
---|---|
void |
EPDataFlowInstantiationOptions.setSurrogateEventSender(EPRuntimeEventSender surrogateEventSender)
Sets the event sender /runtime to use
|
Modifier and Type | Class and Description |
---|---|
class |
EPRuntimeImpl
Implements runtime interface.
|
class |
EPRuntimeIsolatedImpl
Implementation for isolated runtime.
|
Constructor and Description |
---|
InboundUnitSendWrapped(EventBean theEvent,
EPRuntimeEventSender runtime)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
EPRuntimeEventSender |
DataFlowOpInitializateContext.getRuntimeEventSender() |
Constructor and Description |
---|
DataFlowOpInitializateContext(String dataflowName,
String dataflowInstanceId,
Object dataflowInstanceUserObject,
Map<Integer,DataFlowOpInputPort> inputPorts,
Map<Integer,DataFlowOpOutputPort> outputPorts,
StatementContext statementContext,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
EPRuntimeEventSender runtimeEventSender,
EPServiceProvider engine,
Annotation[] operatorAnnotations) |
Modifier and Type | Method and Description |
---|---|
EventSender |
EventAdapterServiceImpl.getDynamicTypeEventSender(EPRuntimeEventSender epRuntime,
URI[] uri,
ThreadingService threadingService) |
EventSender |
EventAdapterService.getDynamicTypeEventSender(EPRuntimeEventSender runtimeEventSender,
URI[] uri,
ThreadingService threadingService)
Returns an event sender that dynamically decides what the event type for a given object is.
|
EventSender |
EventAdapterServiceImpl.getStaticTypeEventSender(EPRuntimeEventSender runtimeEventSender,
String eventTypeName,
ThreadingService threadingService) |
EventSender |
EventAdapterService.getStaticTypeEventSender(EPRuntimeEventSender runtimeEventSender,
String eventTypeName,
ThreadingService threadingService)
Returns an event sender for a specific type, only generating events of that type.
|
Constructor and Description |
---|
EventSenderAvro(EPRuntimeEventSender runtimeEventSender,
EventType eventType,
EventAdapterService eventAdapterService,
ThreadingService threadingService)
Ctor.
|
EventSenderBean(EPRuntimeEventSender runtime,
BeanEventType beanEventType,
EventAdapterService eventAdapterService,
ThreadingService threadingService)
Ctor.
|
EventSenderImpl(List<EventSenderURIDesc> handlingFactories,
EPRuntimeEventSender epRuntime,
ThreadingService threadingService)
Ctor.
|
EventSenderMap(EPRuntimeEventSender runtimeEventSender,
MapEventType mapEventType,
EventAdapterService eventAdapterService,
ThreadingService threadingService)
Ctor.
|
EventSenderObjectArray(EPRuntimeEventSender runtimeEventSender,
ObjectArrayEventType objectArrayEventType,
EventAdapterService eventAdapterService,
ThreadingService threadingService)
Ctor.
|
EventSenderXMLDOM(EPRuntimeEventSender runtimeEventSender,
BaseXMLEventType baseXMLEventType,
EventAdapterService eventAdapterService,
ThreadingService threadingService)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
EventSender |
PlugInEventTypeHandler.getSender(EPRuntimeEventSender runtimeEventSender)
Returns a facility responsible for converting or wrapping event objects.
|