[GitHub] samza pull request #382: SAMZA-1437: Added Eventhub producer and consumer do...

2017-12-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/382 ---

[GitHub] samza pull request #383: SAMZA-1502: Make AllSspToSingleTaskGrouper work wit...

2017-12-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/383 ---

[GitHub] samza pull request #381: SAMZA-1512: Documentation on the multi-stage batch ...

2017-12-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/381 ---

[GitHub] samza pull request #386: Support for UDFs in where clauses

2017-12-12 Thread srinipunuru
GitHub user srinipunuru opened a pull request: https://github.com/apache/samza/pull/386 Support for UDFs in where clauses The existing version of the udf implementation doesn't seem to supported in the where clauses because the Type of the object returned is "ANY" and when you do a

[GitHub] samza pull request #385: SAMZA-1534: Fix the visualization in job graph with...

2017-12-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/385 ---

[GitHub] samza pull request #385: SAMZA-1534: Fix the visualization in job graph with...

2017-12-12 Thread xinyuiscool
GitHub user xinyuiscool opened a pull request: https://github.com/apache/samza/pull/385 SAMZA-1534: Fix the visualization in job graph with the new PartitionBy Op Seems the stream and the partitionBy op has the same id. So in rendering I added the stream as the id for the node. Also

[GitHub] samza pull request #374: Documentation for Samza SQL

2017-12-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/374 ---

[GitHub] samza pull request #384: Adding docs for Kinesis consumer

2017-12-12 Thread atoomula
GitHub user atoomula opened a pull request: https://github.com/apache/samza/pull/384 Adding docs for Kinesis consumer You can merge this pull request into a Git repository by running: $ git pull https://github.com/atoomula/samza kinesis-docs Alternatively you can review and a