GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/421
Support source types where the last part of the source is not the streamName
Contains following fixes
1. Right now Samza SQL framework assumes that the last part of the source
is the stream Name, removed the assumption
2. Made consoleLoggingSystemFactory to log formatted json so that it's
easily readable.
3. Added support in SamzaSqlRelMessage where the key may not be present.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/srinipunuru/samza four-part.1
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/421.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #421
----
commit 3ebe47f97633d5709dca7533097e24c1950ef12b
Author: Srinivasulu Punuru <spunuru@...>
Date: 2018-02-09T00:30:46Z
Support source types where the last part of the source is not the stream
name
----
---
