Sign in
apache
/
storm
/
refs/heads/0.5.0
/
.
/
src
/
dev
/
resources
/
tester.py
blob: b38007c50e79ef18411c1f044ac965a4fe2f4c78 [
file
] [
log
] [
blame
]
import
storm
class
TesterBolt
(
storm
.
Bolt
):
def
process
(
self
,
tup
):
storm
.
emit
([
tup
.
values
[
0
]+
"lalala"
])
storm
.
ack
(
tup
)
TesterBolt
().
run
()
