Sha256: 2adfbec6ffdbab1fbb538afd6c9df3c83b0295a64829a7859b1a022d57631ca6
Contents?: true
Size: 775 Bytes
Versions: 52
Compression:
Stored size: 775 Bytes
Contents
require 'pp'
require 'norikra/query'
require 'norikra/output_pool'
require 'norikra/engine'
pool = Norikra::OutputPool.new
query = Norikra::Query.new(
:name => 'OrderEvent over 150 price counts per 10secs',
:tablename => 'OrderEvent',
:expression => 'select count(*) AS cnt from OrderEvent.win:time_batch(10 seconds) where cast(price,double) > 150'
)
engine = Norikra::Engine.new(pool)
engine.register(query)
flag = true
thread = Thread.new do
while flag
sleep 1
results = pool.pop('OrderEvent over 150 price counts per 10secs')
pp(results) if results.size > 0
end
end
t = Time.now + 35
while Time.now < t
engine.send('OrderEvent', [{"itemName"=>"test","price"=>150}, {"itemName"=>"test","price"=>200}])
sleep 3
end
flag = false
thread.join
Version data entries
52 entries across 52 versions & 1 rubygems