GitHub user prateekm reopened a pull request:
https://github.com/apache/samza/pull/92
SAMZA-1094: Remove MessageEnvelope from public operator APIs. SAMZA-1101:
Delay the creation of SinkFunction for output streams. SAMZA-1159: Move
StreamSpec from a public API to an internal class.
Removed the MessageEnvelope and OutputStream interfaces from public
operator APIs.
Moved the creation of SinkFunction for output streams to SinkOperatorSpec.
Moved StreamSpec from a public API to an internal class.
Additionally,
1. Removed references to StreamGraph in OperatorSpecs. It was being used to
getNextOpId(). MessageStreamsImpl now gets the ID and gives it to OperatorSpecs
itself.
2. Updated and cleaned up the StreamGraphBuilder examples.
3. Renamed SinkOperatorSpec to OutputOperatorSpec since its used by sink,
sendTo and partitionBy.
@nickpan47 and @xinyuiscool, please take a look.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/prateekm/samza message-envelope-removal
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/92.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 #92
----
commit c3ae02dcf388db12d595674732643b1828052497
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Date: 2017-03-17T21:32:52Z
SAMZA-1094, SAMZA-1101: Remove MessageEnvelope from public operator APIs.
Delay the creation of SinkFunction for output streams.
commit 865b9db99fd1c9ac34e84cdef7130f0dfd5261d5
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Date: 2017-03-20T21:04:41Z
Removed unused method. Minor additional cleanup.
commit c98a0806fc95cdcc004900dde647517fd8b4c8ea
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Date: 2017-03-22T00:03:39Z
SAMZA-1159: Move StreamSpec from a public API to an internal class.
----
---
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.
---
