...
BaseTimeUnit: Timeunit used for long based input start/endtimestamps (be careful, the option is case sensitive). The TimeUnits are case sensitive as well, e.g. SECONDS (https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html)
Example
PQL
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({source='Source', wrapper='GenericPush', transport='TCPClient', protocol='CSV', dataHandler='Tuple', METAATTRIBUTE = ['TimeInterval','Latency','Datarate'], /// or: METAATTRIBUTE = 'TimeIntervalLatencyDatarate' options=[['host', 'example.com'],['port', '8080'],['read', '10240'],['write', '10240']], schema=[ ['id', 'Double'], ['data', 'String']] }) |