Package | Description |
---|---|
com.espertech.esper.common.client.context |
Context partition selection and descriptors.
|
com.espertech.esper.common.client.fireandforget |
Classes related to fire-and-forget execution
|
com.espertech.esper.common.client.variable |
Classes for variable management
|
com.espertech.esper.common.internal.context.controller.category | |
com.espertech.esper.common.internal.context.controller.core | |
com.espertech.esper.common.internal.context.controller.hash | |
com.espertech.esper.common.internal.context.controller.initterm | |
com.espertech.esper.common.internal.context.controller.keyed | |
com.espertech.esper.common.internal.context.mgr | |
com.espertech.esper.common.internal.context.util | |
com.espertech.esper.common.internal.epl.fafquery.querymethod |
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 |
---|---|
Set<Integer> |
EPContextPartitionService.getContextPartitionIds(String deploymentId,
String contextName,
ContextPartitionSelector selector)
Returns the context partition ids.
|
ContextPartitionCollection |
EPContextPartitionService.getContextPartitions(String deploymentId,
String contextName,
ContextPartitionSelector selector)
Returns information about selected context partitions including state.
|
Modifier and Type | Method and Description |
---|---|
EPFireAndForgetQueryResult |
EPFireAndForgetPreparedQuery.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.
|
Modifier and Type | Method and Description |
---|---|
Map<DeploymentIdNamePair,List<ContextPartitionVariableState>> |
EPVariableService.getVariableValue(Set<DeploymentIdNamePair> variableNames,
ContextPartitionSelector contextPartitionSelector)
Returns the current variable values for a context-partitioned variable, per context partition.
|
Modifier and Type | Method and Description |
---|---|
void |
ContextControllerCategory.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector contextPartitionSelector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
void |
ContextControllerCategory.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector contextPartitionSelector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
Modifier and Type | Method and Description |
---|---|
void |
ContextControllerLifecycleCallback.contextPartitionRecursiveVisit(IntSeqKey controllerPath,
int subpathId,
ContextController originator,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
void |
ContextController.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector selector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
void |
ContextController.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector selector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
Modifier and Type | Method and Description |
---|---|
void |
ContextControllerHash.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector selector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
void |
ContextControllerHash.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector selector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
Modifier and Type | Method and Description |
---|---|
void |
ContextControllerInitTerm.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector selector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
void |
ContextControllerInitTerm.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector selector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
Modifier and Type | Method and Description |
---|---|
void |
ContextControllerKeyed.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector selector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
void |
ContextControllerKeyed.visitSelectedPartitions(IntSeqKey path,
ContextPartitionSelector selector,
ContextPartitionVisitor visitor,
ContextPartitionSelector[] selectorPerLevel) |
Modifier and Type | Method and Description |
---|---|
Iterator<EventBean> |
ContextIteratorHandler.iterator(int statementId,
ContextPartitionSelector selector) |
SafeIterator<EventBean> |
ContextIteratorHandler.safeIterator(int statementId,
ContextPartitionSelector selector) |
Modifier and Type | Method and Description |
---|---|
EPPreparedQueryResult |
FAFQueryMethodSelect.execute(AtomicBoolean serviceStatusProvider,
FAFQueryMethodAssignerSetter assignerSetter,
ContextPartitionSelector[] contextPartitionSelectors,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethodIUDBase.execute(AtomicBoolean serviceStatusProvider,
FAFQueryMethodAssignerSetter assignerSetter,
ContextPartitionSelector[] contextPartitionSelectors,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethod.execute(AtomicBoolean serviceStatusProvider,
FAFQueryMethodAssignerSetter assignerSetter,
ContextPartitionSelector[] contextPartitionSelectors,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethodSelectExecSomeContextNoJoin.execute(FAFQueryMethodSelect select,
ContextPartitionSelector[] contextPartitionSelectors,
FAFQueryMethodAssignerSetter assignerSetter,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethodSelectExecSomeContextJoin.execute(FAFQueryMethodSelect select,
ContextPartitionSelector[] contextPartitionSelectors,
FAFQueryMethodAssignerSetter assignerSetter,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethodSelectExecNoContextNoJoin.execute(FAFQueryMethodSelect select,
ContextPartitionSelector[] contextPartitionSelectors,
FAFQueryMethodAssignerSetter assignerSetter,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethodSelectExecNoContextNoFromClause.execute(FAFQueryMethodSelect select,
ContextPartitionSelector[] contextPartitionSelectors,
FAFQueryMethodAssignerSetter assignerSetter,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethodSelectExecNoContextJoin.execute(FAFQueryMethodSelect select,
ContextPartitionSelector[] contextPartitionSelectors,
FAFQueryMethodAssignerSetter assignerSetter,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethodSelectExecGivenContextNoJoin.execute(FAFQueryMethodSelect select,
ContextPartitionSelector[] contextPartitionSelectors,
FAFQueryMethodAssignerSetter assignerSetter,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethodSelectExecGivenContextNoFromClause.execute(FAFQueryMethodSelect select,
ContextPartitionSelector[] contextPartitionSelectors,
FAFQueryMethodAssignerSetter assignerSetter,
ContextManagementService contextManagementService) |
EPPreparedQueryResult |
FAFQueryMethodSelectExec.execute(FAFQueryMethodSelect select,
ContextPartitionSelector[] contextPartitionSelectors,
FAFQueryMethodAssignerSetter assignerSetter,
ContextManagementService contextManagementService) |
Copyright © 2005–2021. All rights reserved.