Package | Description |
---|---|
com.espertech.esper.adapter |
Adapter shared classes.
|
com.espertech.esper.client |
This package and its sub-packages defines the central Esper Client APIs.
|
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.dataflow.core |
Data flow core classes.
|
com.espertech.esper.dataflow.interfaces |
Data flow operator and related interface.
|
com.espertech.esper.dataflow.ops |
Data flow built-in operators.
|
com.espertech.esper.dataflow.util |
Data flow utility classes such as internal model, matching and planning.
|
com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
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.
|
com.espertech.esper.util |
Utility classes that center around Java type handling, printing, reflection, debugging
|
Modifier and Type | Method and Description |
---|---|
EPServiceProvider |
AdapterSPI.getEPServiceProvider()
Returns the engine instance.
|
Modifier and Type | Method and Description |
---|---|
void |
BaseSubscription.registerAdapter(EPServiceProvider epService)
Register an adapter.
|
void |
AdapterSPI.setEPServiceProvider(EPServiceProvider epService)
An adapter takes an engine instance to process events.
|
Modifier and Type | Method and Description |
---|---|
static EPServiceProvider |
EPServiceProviderManager.getDefaultProvider()
Returns the default EPServiceProvider.
|
static EPServiceProvider |
EPServiceProviderManager.getDefaultProvider(Configuration configuration)
Returns the default EPServiceProvider.
|
static EPServiceProvider |
EPServiceProviderManager.getExistingProvider(String providerURI)
Returns an existing provider.
|
static EPServiceProvider |
EPServiceProviderManager.getProvider(String providerURI)
Returns an EPServiceProvider for a given provider URI.
|
static EPServiceProvider |
EPServiceProviderManager.getProvider(String providerURI,
Configuration configuration)
Returns an EPServiceProvider for a given provider URI.
|
Modifier and Type | Method and Description |
---|---|
void |
EPServiceStateListener.onEPServiceDestroyRequested(EPServiceProvider serviceProvider)
Invoked before an
EPServiceProvider is destroyed. |
void |
EPServiceStateListener.onEPServiceInitialized(EPServiceProvider serviceProvider)
Invoked after an existing
EPServiceProvider is initialized upon completion of a call to initialize. |
void |
EPStatementStateListener.onStatementCreate(EPServiceProvider serviceProvider,
EPStatement statement)
Called to indicate that a new statement has been created in stopped state.
|
void |
EPStatementStateListener.onStatementStateChange(EPServiceProvider serviceProvider,
EPStatement statement)
Called to indicate that a statement has changed state.
|
void |
StatementAwareUpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPServiceProvider epServiceProvider)
Notify that new events are available or old events are removed.
|
Modifier and Type | Method and Description |
---|---|
EPServiceProvider |
EPDataFlowIRStreamCollectorContext.getEpServiceProvider()
Returns the engine instance.
|
Modifier and Type | Method and Description |
---|---|
void |
EPDataFlowIRStreamCollectorContext.setEpServiceProvider(EPServiceProvider epServiceProvider)
Sets engine instance.
|
Constructor and Description |
---|
EPDataFlowIRStreamCollectorContext(EPDataFlowEmitter emitter,
boolean submitEventBean,
EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPServiceProvider epServiceProvider)
Ctor.
|
Modifier and Type | Interface and Description |
---|---|
interface |
EPServiceProviderSPI
A service provider interface that makes available internal engine services.
|
Modifier and Type | Class and Description |
---|---|
class |
EPServiceProviderImpl
Service provider encapsulates the engine's services for runtime and administration interfaces.
|
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
EPServicesContextFactoryDefault.createServicesContext(EPServiceProvider epServiceProvider,
ConfigurationInformation configSnapshot) |
EPServicesContext |
EPServicesContextFactory.createServicesContext(EPServiceProvider epServiceProvider,
ConfigurationInformation configurationSnapshot)
Factory method for a new set of engine services.
|
Constructor and Description |
---|
StatementEventDispatcherUnthreaded(EPServiceProvider serviceProvider,
Iterable<EPStatementStateListener> statementListeners)
Ctor.
|
StatementLifecycleSvcImpl(EPServiceProvider epServiceProvider,
EPServicesContext services)
Ctor.
|
Constructor and Description |
---|
DataFlowServiceImpl(EPServiceProvider epService,
DataFlowConfigurationStateService configurationState) |
Modifier and Type | Method and Description |
---|---|
EPServiceProvider |
DataFlowOpInitializateContext.getEngine() |
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 |
---|---|
void |
EPStatementSource.EmitterUpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPServiceProvider epServiceProvider) |
void |
EPStatementSource.EmitterCollectorUpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPServiceProvider epServiceProvider) |
Modifier and Type | Method and Description |
---|---|
static void |
DefaultSupportGraphEventUtil.addTypeConfiguration(EPServiceProvider epService) |
Modifier and Type | Method and Description |
---|---|
static void |
InstrumentationHelper.startTest(EPServiceProvider engine,
Class testClass,
String testName) |
void |
InstrumentationAssertionService.startTest(EPServiceProvider engine,
Class testClass,
String testName) |
Modifier and Type | Method and Description |
---|---|
EPServiceProvider |
PluginLoaderInitContext.getEpServiceProvider()
Returns the engine loading the plugin.
|
Constructor and Description |
---|
PluginLoaderInitContext(String name,
Properties properties,
String configXml,
EPServiceProvider epService)
Initialization context for use with the adapter loader.
|
Modifier and Type | Method and Description |
---|---|
static EventRepresentationChoice |
EventRepresentationChoice.getEngineDefault(EPServiceProvider engine) |
Modifier and Type | Method and Description |
---|---|
static void |
StatementSelectionUtil.applyExpressionToStatements(EPServiceProviderSPI engine,
String filter,
BiConsumer<EPServiceProvider,EPStatement> consumer) |