Norikra上でマスタデータ等とJOINするのに使えるnorikra-udf-lookupを作った ref: http://qiita.com/ogibayashi/items/67b37904cae3b47cf407

file0.txt

gem 'norikra-udf-lookup'

file1.txt

$ gem install norikra-udf-lookup

file2.txt

% cat /tmp/lookuptest.tsv 
1       aaa
2       bbb
3       ccc

file3.txt

SELECT
  id, lookup_tsv('/tmp/lookuptest.tsv',id,'not found') as name, count(*) as cnt
FROM
  test_stream.win:time_batch(1 min)
GROUP by id

file4.txt

% echo '{"id":"1"}' | norikra-client event send test_stream
% echo '{"id":"2"}' | norikra-client event send test_stream
% echo '{"id":"3"}' | norikra-client event send test_stream
% echo '{"id":"4"}' | norikra-client event send test_stream

file5.txt

% norikra-client event sweep
{"time":"2015/07/28 12:13:24","query":"lookuptest","id":"3","cnt":1,"name":"ccc"}
{"time":"2015/07/28 12:13:24","query":"lookuptest","id":"2","cnt":1,"name":"bbb"}
{"time":"2015/07/28 12:13:24","query":"lookuptest","id":"1","cnt":1,"name":"aaa"}
{"time":"2015/07/28 12:13:24","query":"lookuptest","id":"4","cnt":1,"name":"not found"}