com.espertech.esper.common.internal.epl.dataflow.ops

Class EventBusSourceForge

java.lang.Object

com.espertech.esper.common.internal.epl.dataflow.ops.EventBusSourceForge

All Implemented Interfaces:

DataFlowOperatorForge

public class EventBusSourceForge
extends Object
implements DataFlowOperatorForge

Field Summary

Fields

Modifier and Type	Field and Description
protected EPDataFlowEventBeanCollector	collector
protected ExprNode	filter

Constructor Summary

Constructors

Constructor and Description
EventBusSourceForge()

Method Summary

Modifier and Type	Method and Description
FilterSpecCompiled	getFilterSpecCompiled()
DataFlowOpForgeInitializeResult	initializeForge(DataFlowOpForgeInitializeContext context)
CodegenExpression	make(CodegenMethodScope parent, SAIFFInitializeSymbol symbols, CodegenClassScope classScope)

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

Constructor Detail

EventBusSourceForge

public EventBusSourceForge()

Method Detail

initializeForge

public DataFlowOpForgeInitializeResult initializeForge(DataFlowOpForgeInitializeContext context)
                                                throws ExprValidationException

Specified by:

initializeForge in interface DataFlowOperatorForge

Throws:

ExprValidationException

make

public CodegenExpression make(CodegenMethodScope parent,
                              SAIFFInitializeSymbol symbols,
                              CodegenClassScope classScope)

Specified by:

make in interface DataFlowOperatorForge

getFilterSpecCompiled

public FilterSpecCompiled getFilterSpecCompiled()