This operator can be used to enrich stream objects with information from a database.
#PARSER PQL #QUERY out = dbenrich({connection='connectionName', query='SELECT * FROM mytable', attributes=[]}, nexmark:person)) out = dbenrich({connection='connectionName', query='SELECT name, description FROM categories WHERE id=?', attributes=['category']}, nexmark:auction)) |