GitHub user tdas opened a pull request:
https://github.com/apache/spark/pull/5695
[SPARK-7138][Streaming] Add method to BlockGenerator to add multiple
records to BlockGenerator with single callback
This is to ensure that receivers that receive data in small batches (like
Kinesis) and want to add them but want the callback function to be called only
once. This is for internal use only for improvement to Kinesis Receiver that we
are planning to do.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tdas/spark SPARK-7138
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/5695.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 #5695
----
commit a7a4cb9e8ca5053e9e82ed72ef02e56003ebe3c2
Author: Tathagata Das <[email protected]>
Date: 2015-04-24T22:03:57Z
Added extra method to BlockGenerator.
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
