com.espertech.esper.dataflow.ops

Class EventBusSource

java.lang.Object

com.espertech.esper.dataflow.ops.EventBusSource

All Implemented Interfaces:

DataFlowOpLifecycle, DataFlowSourceOperator, FilterHandle, FilterHandleCallback

public class EventBusSource
extends java.lang.Object
implements DataFlowSourceOperator, DataFlowOpLifecycle, FilterHandleCallback

Field Summary

Fields

Modifier and Type	Field and Description
protected AgentInstanceContext	agentInstanceContext
protected EPStatementHandleCallback	callbackHandle
protected EPDataFlowEventBeanCollector	collector
protected java.util.concurrent.LinkedBlockingDeque<java.lang.Object>	emittables
protected EventType	eventType
protected ExprNode	filter
protected FilterServiceEntry	filterServiceEntry
protected EPDataFlowEmitter	graphContext
protected boolean	submitEventBean

Constructor Summary

Constructors

Constructor and Description
EventBusSource()

Method Summary

Modifier and Type	Method and Description
void	close(DataFlowOpCloseContext openContext)
int	getStatementId() Returns the statement id.
DataFlowOpInitializeResult	initialize(DataFlowOpInitializateContext context)
boolean	isSubSelect() Returns true if the filter applies to subselects.
void	matchFound(EventBean theEvent, java.util.Collection<FilterHandleCallback> allStmtMatches) Indicate that an event was evaluated by the FilterService which matches the filter specification FilterSpecCompiled associated with this callback.
void	next()
void	open(DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

filter

protected ExprNode filter

collector

protected EPDataFlowEventBeanCollector collector

graphContext

protected EPDataFlowEmitter graphContext

eventType

protected EventType eventType

agentInstanceContext

protected AgentInstanceContext agentInstanceContext

callbackHandle

protected EPStatementHandleCallback callbackHandle

filterServiceEntry

protected FilterServiceEntry filterServiceEntry

emittables

protected java.util.concurrent.LinkedBlockingDeque<java.lang.Object> emittables

submitEventBean

protected boolean submitEventBean

Constructor Detail

EventBusSource

public EventBusSource()

Method Detail

initialize

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
                                      throws java.lang.Exception

Specified by:

initialize in interface DataFlowOpLifecycle

Throws:

java.lang.Exception

next

public void next()
          throws java.lang.InterruptedException

Specified by:

next in interface DataFlowSourceOperator

Throws:

java.lang.InterruptedException

matchFound

public void matchFound(EventBean theEvent,
                       java.util.Collection<FilterHandleCallback> allStmtMatches)

Description copied from interface: FilterHandleCallback

Indicate that an event was evaluated by the FilterService which matches the filter specification FilterSpecCompiled associated with this callback.

Specified by:

matchFound in interface FilterHandleCallback

Parameters:

theEvent - - the event received that matches the filter specification

allStmtMatches - - collection of matches that represent all matches for the same statement

isSubSelect

public boolean isSubSelect()

Description copied from interface: FilterHandleCallback

Returns true if the filter applies to subselects.

Specified by:

isSubSelect in interface FilterHandleCallback

Returns:

subselect filter

getStatementId

public int getStatementId()

Description copied from interface: FilterHandle

Returns the statement id.

Specified by:

getStatementId in interface FilterHandle

Returns:

statement id

open

public void open(DataFlowOpOpenContext openContext)

Specified by:

open in interface DataFlowOpLifecycle

close

public void close(DataFlowOpCloseContext openContext)

Specified by:

close in interface DataFlowOpLifecycle