...
| Event method | Description |
|---|---|
processNext(IStreamObject object, int port) | New stream element is received |
processPunctuation(IPunctuation punctuation, int port) | New punctuation is received |
processOpen() | Processing has started |
processClose() | Processing has stopped |
processDone() | No more stream elements are sent |
processDone(int port) | No more stream elements are sent by from a source |
createOutputSchema (int port) | Output schema has to be created |
sourceSubscribed() | New source is subscribed |
sourceUnsubscribed() | Source is unsubscribed |
ao_init() | Logical operator is initialized |
po_init() | Physical operator is initialized |
...