com.espertech.esper.runtime.internal.dataflow.op.eventbussink

Class EventBusSinkFactory

java.lang.Object

com.espertech.esper.runtime.internal.dataflow.op.eventbussink.EventBusSinkFactory

All Implemented Interfaces:

com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

public class EventBusSinkFactory
extends Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

Constructor Summary

Constructors

Constructor and Description
EventBusSinkFactory()

Method Summary

Modifier and Type	Method and Description
com.espertech.esper.common.internal.event.core.EventBeanAdapterFactory[]	getAdapterFactories()
Map<String,Object>	getCollector()
void	initializeFactory(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpFactoryInitializeContext context)
com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator	operator(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)
void	setCollector(Map<String,Object> collector)
void	setEventTypes(com.espertech.esper.common.client.EventType[] eventTypes)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBusSinkFactory

public EventBusSinkFactory()

Method Detail

initializeFactory

public void initializeFactory(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpFactoryInitializeContext context)

Specified by:

initializeFactory in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

operator

public com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator operator(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)

Specified by:

operator in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

setEventTypes

public void setEventTypes(com.espertech.esper.common.client.EventType[] eventTypes)

getAdapterFactories

public com.espertech.esper.common.internal.event.core.EventBeanAdapterFactory[] getAdapterFactories()

setCollector

public void setCollector(Map<String,Object> collector)

getCollector

public Map<String,Object> getCollector()