added gears stream reader

jruaux · jruaux · commit 912b810ceffb · 2021-05-13T12:10:36.000-07:00
diff --git a/src/main/resources/gears/streamreader.py b/src/main/resources/gears/streamreader.py
@@ -0,0 +1,3 @@
+proc = GB('StreamReader')
+proc.foreach(lambda x: execute('SADD', 'myset', x['body']))
+proc.register('mystream')

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+proc = GB('StreamReader')`
	`2`	`+proc.foreach(lambda x: execute('SADD', 'myset', x['body']))`
	`3`	`+proc.register('mystream')`