Package | Description |
---|---|
com.espertech.esper.common.client.dataflow.core |
Client API for data flows.
|
com.espertech.esper.common.internal.context.util | |
com.espertech.esper.common.internal.event.arr |
Object-array event type.
|
com.espertech.esper.common.internal.event.avro |
Avro event type core interfaces.
|
com.espertech.esper.common.internal.event.bean.core |
JavaBean and legacy Java underlying event classes are here.
|
com.espertech.esper.common.internal.event.map |
Map-underlying event classes are here.
|
com.espertech.esper.common.internal.event.xml |
XML event wrappers
|
com.espertech.esper.common.internal.statement.thread |
Modifier and Type | Method and Description |
---|---|
EPRuntimeEventProcessWrapped |
EPDataFlowInstantiationOptions.getSurrogateEventSender()
Returns the event sender /runtime to use
|
Modifier and Type | Method and Description |
---|---|
void |
EPDataFlowInstantiationOptions.setSurrogateEventSender(EPRuntimeEventProcessWrapped surrogateEventSender)
Sets the event sender /runtime to use
|
Modifier and Type | Method and Description |
---|---|
EPRuntimeEventProcessWrapped |
StatementContextRuntimeServices.getEPRuntimeEventProcessWrapped() |
EPRuntimeEventProcessWrapped |
StatementContext.getEPRuntimeEventProcessWrapped() |
EPRuntimeEventProcessWrapped |
AgentInstanceContext.getEPRuntimeEventProcessWrapped() |
Constructor and Description |
---|
StatementContextRuntimeServices(ContextManagementService contextManagementService,
ContextServiceFactory contextServiceFactory,
DatabaseConfigServiceRuntime databaseConfigService,
DataFlowFilterServiceAdapter dataFlowFilterServiceAdapter,
EPDataFlowServiceImpl dataflowService,
String runtimeURI,
Context runtimeEnvContext,
ClasspathImportServiceRuntime classpathImportServiceRuntime,
RuntimeSettingsService runtimeSettingsService,
RuntimeExtensionServices runtimeExtensionServices,
Object epRuntime,
EPRenderEventService epRuntimeRenderEvent,
EventServiceSendEventCommon eventServiceSendEventInternal,
EPRuntimeEventProcessWrapped epRuntimeEventProcessWrapped,
EventBeanService eventBeanService,
EventBeanTypedEventFactory eventBeanTypedEventFactory,
EventTableIndexService eventTableIndexService,
EventTypeAvroHandler eventTypeAvroHandler,
PathRegistry<String,EventType> eventTypePathRegistry,
EventTypeRepositoryImpl eventTypeRepositoryPreconfigured,
EventTypeResolvingBeanFactory eventTypeResolvingBeanFactory,
ExceptionHandlingService exceptionHandlingService,
ExpressionResultCacheService expressionResultCacheService,
FilterService filterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
FilterSharedBoolExprRepository filterSharedBoolExprRepository,
FilterSharedLookupableRepository filterSharedLookupableRepository,
HistoricalDataCacheFactory historicalDataCacheFactory,
InternalEventRouter internalEventRouter,
InternalEventRouteDest internalEventRouteDest,
MetricReportingService metricReportingService,
NamedWindowConsumerManagementService namedWindowConsumerManagementService,
NamedWindowManagementService namedWindowManagementService,
PathRegistry<String,ContextMetaData> pathContextRegistry,
PathRegistry<String,NamedWindowMetaData> pathNamedWindowRegistry,
RowRecogStateRepoFactory rowRecogStateRepoFactory,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
SchedulingService schedulingService,
StatementAgentInstanceLockFactory statementAgentInstanceLockFactory,
StatementResourceHolderBuilder statementResourceHolderBuilder,
TableExprEvaluatorContext tableExprEvaluatorContext,
TableManagementService tableManagementService,
VariableManagementService variableManagementService,
ViewFactoryService viewFactoryService,
ViewServicePreviousFactory viewServicePreviousFactory) |
Constructor and Description |
---|
EventSenderObjectArray(EPRuntimeEventProcessWrapped runtimeEventSender,
ObjectArrayEventType objectArrayEventType,
EventBeanTypedEventFactory eventBeanTypedEventFactory,
ThreadingCommon threadingService)
Ctor.
|
Constructor and Description |
---|
EventSenderAvro(EPRuntimeEventProcessWrapped runtimeEventSender,
EventType eventType,
EventBeanTypedEventFactory eventBeanTypedEventFactory,
ThreadingCommon threadingService)
Ctor.
|
Constructor and Description |
---|
EventSenderBean(EPRuntimeEventProcessWrapped runtime,
BeanEventType beanEventType,
EventBeanTypedEventFactory eventBeanTypedEventFactory,
ThreadingCommon threadingService)
Ctor.
|
Constructor and Description |
---|
EventSenderMap(EPRuntimeEventProcessWrapped runtimeEventSender,
MapEventType mapEventType,
EventBeanTypedEventFactory eventBeanTypedEventFactory,
ThreadingCommon threadingService)
Ctor.
|
Constructor and Description |
---|
EventSenderXMLDOM(EPRuntimeEventProcessWrapped runtimeEventSender,
BaseXMLEventType baseXMLEventType,
EventBeanTypedEventFactory eventBeanTypedEventFactory,
ThreadingCommon threadingService)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
void |
ThreadingCommon.submitInbound(EventBean event,
EPRuntimeEventProcessWrapped runtimeEventSender) |
Copyright © 2005–2018. All rights reserved.