Versions Compared

Old Version 15

changes.mady.by.user user-a8459

Saved on

compared with

New Version Current

changes.mady.by.user user-a8459

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

The following table shows the available metadata:

MetadataPossible values
outputmode outputMode (important)
  • "INPUT"
    • read element wil not be modified
  • "MODIFIED_INPUT" (default)
    • read element will be modified
  • "NEW_ELEMENT"
    • operator creates a new element
persistent
  • true
    • operator will be automatically added to operator framework after each start of Odysseus
  • false (default)
minInputPorts
  • Integer-Value (default 1)
    • Minimal number of ports that the operator needs
maxInputPorts
  • Integer-Value (default 2147483647)
    • Maximum number of ports that the operator needs

...

Event methodDescription

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
titleGrammar
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.

...