GitHub user xinyuiscool opened a pull request:
https://github.com/apache/samza/pull/207
SAMZA-1312: Add Control Messages and Intermediate Stream Serde
In this patch, we add the control message types which includes:
* EndOfStreamMessage
* WatermarkMessage
To support in-band data and control messages, we provide a wrapper serde
(IntermediateMessageSerde) to serialize/deserialize data/control messages based
on message type byte (first byte in the intermediate stream message). The
format of the message is defined in SAMZA-1312. The patch integrates this serde
with SerdeManager.
Tested in example jobs deployed locally and works as expected.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/xinyuiscool/samza SAMZA-1312
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/207.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 #207
----
commit f0bb67f26204fc5698f5d9b5fbdac8b90c70fabe
Author: Xinyu Liu <xi...@xiliu-ld.linkedin.biz>
Date: 2017-05-26T22:01:05Z
Add control message types and serde
commit 2d79ed7a8a6f4698904232899ef485c4f3a1e627
Author: Xinyu Liu <xi...@xiliu-ld.linkedin.biz>
Date: 2017-05-30T22:41:12Z
Clean up the ControlMessage class and some enhancements
commit f0e32d517942fb119253e2d4f06fc921c34ec0ba
Author: Xinyu Liu <xi...@xiliu-ld.linkedin.biz>
Date: 2017-05-31T00:52:49Z
Merge branch 'master' into SAMZA-1312
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
