...

• path:String: In which folder should the processing result be written
• delimitter: Char: What should be the delimitter for the separation of elements in the CSV output (these parameters are used in CSVFileSink
• stopafterelements:Long: Integrates the Close Stream Operator after each source. The query stops after one source has read at least stopafterelements elements
• stopafterelementswritten:Long: Integrated the Close Stream Operator before the sink, which means, the processing stops after stopafterelementswritten have been written
• stopafterpredicte: String: Integrates the Close Stream Operator after each source. The query stops, if the condition for one source is true, e.g. "stopafterpredicate=TimeInterval.START>10000" stops, if the timestamp of the metadata of the source is larger than 10000. See Close Stream Operator for more examples

All the generic parameter can be used in the following three Evaluation handlers. If no path is given, no output will be created. When using stop* parameters, these should only be part of one of the handlers.

Latency (core) 

See Latency for more information about this metadata.

...

See Systemload Metadata for more information about this metadata.

#PRETRANSFORM SystemloadEvaluation 

Combination

All the evaluation keywords can be combined:

/// Some examples
///#PRETRANSFORM LatencyEvaluation (useMaxLatency=false) (delimmitter=,) (path="I:/tmp/Latencytest/")
///#PRETRANSFORM DatarateEvaluation (updaterate=10) (delimmitter=,) (path="I:/tmp/Dataratetest/")
/// #PRETRANSFORM SystemloadEvaluation (path="I:/tmp/Systemloadtest/")

///#PRETRANSFORM LatencyEvaluation (stopafterelements=10) (stopafterpredicate=TimeInterval.START>10000)
#PRETRANSFORM LatencyEvaluation (stopafterelementswritten=10)
#PRETRANSFORM DatarateEvaluation (updaterate=10) 
///#PRETRANSFORM SystemloadEvaluation 
///#PRETRANSFORM AddSender (transport=AMQP) (wrapper=GenericPush) (protocol=CSV) (datahandler=Tuple) (SINK=SENDER) (QUEUE_NAME=nexmark) (CONSUMER_TAG=bid) (HOST=localhost) (writeMetadata=true)

#PARSER PQL
#RUNQUERY
timer = TIMER({PERIOD = 1000, TIMEFROMSTART = true , SOURCE = 'timerSource'})

map = MAP({EXPRESSIONS = ['sleep(1000)']}, timer)

AddSender

Sometimes it is helpful to add a  Sender operator after the processing to send the data to another receiver. This AddSender cannot be used together with path!

...