Package | Description |
---|---|
com.espertech.esper.client |
This package and its sub-packages defines the central Esper Client APIs.
|
com.espertech.esper.client.context |
Context partition selection and descriptors.
|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
Modifier and Type | Method and Description |
---|---|
EPOnDemandQueryResult |
EPOnDemandPreparedQuery.execute(ContextPartitionSelector[] contextPartitionSelectors)
For use with named windows that have a context declared and that may therefore have multiple context partitions,
allows to target context partitions for query execution selectively.
|
EPOnDemandQueryResult |
EPRuntime.executeQuery(EPOnDemandPreparedQueryParameterized parameterizedQuery,
ContextPartitionSelector[] contextPartitionSelectors)
Execute an on-demand parameterized query.
|
EPOnDemandQueryResult |
EPRuntime.executeQuery(EPStatementObjectModel model,
ContextPartitionSelector[] contextPartitionSelectors)
For use with named windows that have a context declared and that may therefore have multiple context partitions,
allows to target context partitions for query execution selectively.
|
EPOnDemandQueryResult |
EPRuntime.executeQuery(String epl,
ContextPartitionSelector[] contextPartitionSelectors)
For use with named windows that have a context declared and that may therefore have multiple context partitions,
allows to target context partitions for query execution selectively.
|
Map<String,List<ContextPartitionVariableState>> |
EPRuntime.getVariableValue(Set<String> variableNames,
ContextPartitionSelector contextPartitionSelector)
Returns the current variable values for a context-partitioned variable, per context partition.
|
Iterator<EventBean> |
EPStatement.iterator(ContextPartitionSelector selector)
For use with statements that have a context declared and that may therefore have multiple context partitions,
allows to iterate over context partitions selectively.
|
SafeIterator<EventBean> |
EPStatement.safeIterator(ContextPartitionSelector selector)
For use with statements that have a context declared and that may therefore have multiple context partitions,
allows to safe-iterate over context partitions selectively.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ContextPartitionSelectorById
Selects a context partition by providing the context partition id(s).
|
interface |
ContextPartitionSelectorCategory
Selects context partitions for use with a category context by providing a set of labels.
|
interface |
ContextPartitionSelectorFiltered
Selects context partitions by receiving a context partition identifier for interrogation.
|
interface |
ContextPartitionSelectorHash
Selects context partitions based on hash codes, for use with hashed context.
|
interface |
ContextPartitionSelectorNested
Selects context partitions of a nested context by providing selector according to the nested contexts.
|
interface |
ContextPartitionSelectorSegmented
Selector of context partitions for use with segmented contexts, provides a set of partition keys to select.
|
Modifier and Type | Class and Description |
---|---|
class |
ContextPartitionSelectorAll
Selects all context paritions.
|
Modifier and Type | Method and Description |
---|---|
ContextPartitionCollection |
EPContextPartitionAdmin.destroyContextPartitions(String contextName,
ContextPartitionSelector selector)
Destroy one or more context partitions dropping the associated state and removing associated context partition metadata.
|
Set<Integer> |
EPContextPartitionAdmin.getContextPartitionIds(String contextName,
ContextPartitionSelector selector)
Returns the context partition ids.
|
ContextPartitionCollection |
EPContextPartitionAdmin.getContextPartitions(String contextName,
ContextPartitionSelector selector)
Returns information about selected context partitions including state.
|
ContextPartitionCollection |
EPContextPartitionAdmin.startContextPartitions(String contextName,
ContextPartitionSelector selector)
Start one or more context partitions that were previously stopped.
|
ContextPartitionCollection |
EPContextPartitionAdmin.stopContextPartitions(String contextName,
ContextPartitionSelector selector)
Stop one or more context partitions that are currently started, dropping the associated state and but keeping
associated context partition metadata for the purpose of starting it again.
|
Modifier and Type | Method and Description |
---|---|
static InvalidContextPartitionSelector |
ContextControllerSelectorUtil.getInvalidSelector(Class[] choice,
ContextPartitionSelector selector) |
static InvalidContextPartitionSelector |
ContextControllerSelectorUtil.getInvalidSelector(Class[] choice,
ContextPartitionSelector selector,
boolean isNested) |
Iterator<EventBean> |
ContextIteratorHandler.iterator(int statementId,
ContextPartitionSelector selector) |
Iterator<EventBean> |
ContextDescriptor.iterator(int statementId,
ContextPartitionSelector selector) |
SafeIterator<EventBean> |
ContextIteratorHandler.safeIterator(int statementId,
ContextPartitionSelector selector) |
SafeIterator<EventBean> |
ContextDescriptor.safeIterator(int statementId,
ContextPartitionSelector selector) |
Modifier and Type | Class and Description |
---|---|
static class |
EPContextPartitionAdminImpl.CPSelectorById |
Modifier and Type | Method and Description |
---|---|
EPPreparedQueryResult |
EPPreparedExecuteMethodQuery.execute(ContextPartitionSelector[] contextPartitionSelectors)
Executes the prepared query.
|
EPPreparedQueryResult |
EPPreparedExecuteMethod.execute(ContextPartitionSelector[] contextPartitionSelectors) |
EPPreparedQueryResult |
EPPreparedExecuteIUDSingleStream.execute(ContextPartitionSelector[] contextPartitionSelectors)
Executes the prepared query.
|
static Collection<Integer> |
EPPreparedExecuteMethodHelper.getAgentInstanceIds(FireAndForgetProcessor processor,
ContextPartitionSelector selector,
ContextManagementService contextManagementService,
String contextName) |