...
| Code Block |
|---|
#PARSER PQL
#ADDQUERY
in = CONNECTOR({port = 0, SOURCE = 'connector0', SCHEMA = [['test', 'integer']]})
in2 = CONNECTOR({port = 1, SOURCE = 'connector1', SCHEMA = [['test', 'integer']]})
merged = MERGE(in,in2)
out = FILTER({NAME='Test',PREDICATE = 'test % 2 == 0'},merged)
/// TODO: explain
out0 = OUTPUTCONNECTOR({PORT = 0, name="Conn01"}, 0:out)
out1Input = MAP({EXPRESSIONS = ['counter()','test']},1:out)
out1 = OUTPUTCONNECTOR({PORT = 1, name="Conn02"}, out1Input) |
...
As the CONNECTOR is just a source, is can have all parameters like the Access Operators, i.e. is must provide a name and should provide a schema. With the parameter type, the object type can be set (default is tuple). The port parameter is mapped to the position of the subquery operator.
The end of the subquery is defined by the outputconnectors. If, as in the example above, multiple output ports should be available, each port must be defined with this connector.