EventBusSink (Esper API Documentation)

public class EventBusSink
extends java.lang.Object
implements DataFlowOpLifecycle

Constructors
Constructor and Description
`EventBusSink()`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`close(DataFlowOpCloseContext openContext)`
`DataFlowOpInitializeResult`	`initialize(DataFlowOpInitializateContext context)`
`void`	`onInput(int port, java.lang.Object data)`
`void`	`open(DataFlowOpOpenContext openContext)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

public void onInput(int port,
                    java.lang.Object data)

public void open(DataFlowOpOpenContext openContext)

public void close(DataFlowOpCloseContext openContext)

Class EventBusSink