...
| Event method | Description |
|---|---|
processNext(IStreamObject object, int port) | Process a stream element |
processPunctuation(IPunctuation punctuation, int port) | Process a punctuation |
processOpen() |
|
processClose() |
|
processDone() |
|
processDone(int port) |
|
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 |
AO & PO methods
Besides validate and event methods it also possible to create normal methods. The ao-keyword should be used if a method needs to call a method of AbstractLogicalOperator. The po-keyword should be used if a method needs to call a method of AbstractPipe.
...