|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.view.stream.StreamFactorySvcImpl
public class StreamFactorySvcImpl
Service implementation to reuse or not reuse event streams and existing filters depending on the type of statement.
Works together with StreamFactorySvcReuse
for the reuse of event streams when filters match, and thus
when an event stream is reused such can be the views under the stream. For joins however, this can lead to
problems in multithread-safety since the statement resource lock would then have to be multiple locks,
i.e. the reused statement's resource lock and the join statement's own lock, at a minimum.
Works together with StreamFactorySvcCreate
for always creating a new event stream and
therefore not reusing view resources, for use with joins.
Constructor Summary | |
---|---|
StreamFactorySvcImpl()
Ctor. |
Method Summary | |
---|---|
EventStream |
createStream(FilterSpec filterSpec,
FilterService filterService,
EPStatementHandle epStatementHandle,
boolean isJoin)
Create or reuse existing EventStream instance representing that event filter. |
void |
dropStream(FilterSpec filterSpec,
FilterService filterService,
boolean isJoin)
Drop the event stream associated with the filter passed in. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public StreamFactorySvcImpl()
Method Detail |
---|
public EventStream createStream(FilterSpec filterSpec, FilterService filterService, EPStatementHandle epStatementHandle, boolean isJoin)
StreamFactoryService
createStream
in interface StreamFactoryService
filterSpec
- event filter definitionfilterService
- filter service to activate filter if not already activeepStatementHandle
- is the statements-own handle for use in registering callbacks with servicesisJoin
- is indicatng whether the stream will participate in a join statement, information
necessary for stream reuse and multithreading concerns
public void dropStream(FilterSpec filterSpec, FilterService filterService, boolean isJoin)
StreamFactoryService
dropStream
in interface StreamFactoryService
filterSpec
- is the event filter definition associated with the event stream to be droppedfilterService
- to be used to deactivate filter when the last event stream is droppedisJoin
- is indicatng whether the stream will participate in a join statement, information
necessary for stream reuse and multithreading concerns
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |