Package | Description |
---|---|
com.espertech.esper.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
com.espertech.esper.view.stream |
View to event stream relationship service
|
Modifier and Type | Class and Description |
---|---|
class |
ZeroDepthStreamIterable
Event stream implementation that does not keep any window by itself of the events coming into the stream,
however is itself iterable and keeps the last event.
|
class |
ZeroDepthStreamNoIterate
Event stream implementation that does not keep any window by itself of the events coming into the stream,
without the possibility to iterate the last event.
|
Modifier and Type | Method and Description |
---|---|
void |
ViewServiceImpl.remove(EventStream eventStream,
Viewable viewToRemove) |
void |
ViewService.remove(EventStream eventStream,
Viewable view)
Removes a view discoupling the view and any of it's parent views up the tree to the last shared parent view.
|
Modifier and Type | Method and Description |
---|---|
static EventStream |
EventStreamProxy.getAuditProxy(String engineURI,
String statementName,
Annotation[] annotations,
FilterSpecCompiled filterSpec,
EventStream designated) |
Modifier and Type | Method and Description |
---|---|
Pair<EventStream,StatementAgentInstanceLock> |
StreamFactorySvcImpl.createStream(int statementId,
FilterSpecCompiled filterSpec,
FilterService filterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
boolean isJoin,
AgentInstanceContext agentInstanceContext,
boolean hasOrderBy,
boolean filterWithSameTypeSubselect,
Annotation[] annotations,
boolean stateless,
int streamNum,
boolean isCanIterateUnbound)
See the method of the same name in
StreamFactoryService . |
Pair<EventStream,StatementAgentInstanceLock> |
StreamFactoryService.createStream(int statementId,
FilterSpecCompiled filterSpec,
FilterService filterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
boolean isJoin,
AgentInstanceContext agentInstanceContext,
boolean hasOrderBy,
boolean filterWithSameTypeSubselect,
Annotation[] annotations,
boolean stateless,
int streamNum,
boolean isCanIterateUnbound)
Create or reuse existing EventStream instance representing that event filter.
|
Modifier and Type | Method and Description |
---|---|
static EventStream |
EventStreamProxy.getAuditProxy(String engineURI,
String statementName,
Annotation[] annotations,
FilterSpecCompiled filterSpec,
EventStream designated) |
static Object |
EventStreamProxy.newInstance(String engineURI,
String statementName,
String eventTypeAndFilter,
EventStream eventStream) |
Constructor and Description |
---|
EventStreamProxy(String engineURI,
String statementName,
String eventTypeAndFilter,
EventStream eventStream) |