...
The following table shows the available metadata:
Metadata | Possible values |
---|---|
outputmode outputMode (important) |
|
persistent |
|
minInputPorts |
|
maxInputPorts |
|
...
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 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 |
AO & PO methods
Besides validate and event methods it is 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.
...
Code Block | ||
---|---|---|
| ||
ODLModel ::= (Namespace)* (UserOperator | Class | Interface)*. UserOperator ::= "operator" ID ("(" (Metadata ("," Metadata))? ")")? "{" (ODLAttribute | ODLMethod) "}". ODLAttribute ::= (("optional")? "parameter")? ("(" (Metadata ("," Metadata))?* ")")? Attribute. ODLMethod ::= ("on" | "validate" | "override" | ("override")? "ao" | ("override")? "po")? (MethodDeclaration)? StatementBlock. |
...