Sign in
apache
/
storm
/
refs/heads/0.5.0
/
.
/
src
/
dev
/
resources
/
tester.fy
blob: bad0429adeb53aa6828581dfa1e48c6af3f24de7 [
file
] [
log
] [
blame
]
require
:
"storm"
class
TesterBolt
:
Storm
Bolt
{
def
process
:
tuple
{
emit
:
[
tuple values first
+
"lalala"
]
ack
:
tuple
}
}
TesterBolt
new
run
