net.esper.view.stream
Class StreamFactorySvcCreate

java.lang.Object
  extended by net.esper.view.stream.StreamFactorySvcCreate

public class StreamFactorySvcCreate
extends Object

Service implementation to create a new event stream and register newly with the filter service.

Thus views under the newly created event stream are not reused across statements, for multithread-safety.


Constructor Summary
StreamFactorySvcCreate()
          Ctor.
 
Method Summary
 EventStream createStream(FilterSpec filterSpec, FilterService filterService, EPStatementHandle epStatementHandle)
          See the method of the same name in StreamFactoryService.
 void dropStream(FilterSpec filterSpec, FilterService filterService)
          See the method of the same name in StreamFactoryService.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StreamFactorySvcCreate

public StreamFactorySvcCreate()
Ctor.

Method Detail

createStream

public EventStream createStream(FilterSpec filterSpec,
                                FilterService filterService,
                                EPStatementHandle epStatementHandle)
See the method of the same name in StreamFactoryService. Always creates a new event stream.

Parameters:
filterSpec - is the filter definition
filterService - is the filtering service
epStatementHandle - is the statement resource lock
Returns:
newly created event stream, not reusing existing instances

dropStream

public void dropStream(FilterSpec filterSpec,
                       FilterService filterService)
See the method of the same name in StreamFactoryService.

Parameters:
filterSpec - is the filter definition
filterService - is the filtering service