diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2015-04-28 19:31:57 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-04-28 19:31:57 -0700 |
| commit | 5c8f4bd5fae539ab5fb992573d5357ed34e2f4d0 (patch) | |
| tree | d122c478a8b9d763527e153b23fde98e3db23a90 /python | |
| parent | d36e67350c516a96d58abd50a0d5d22b3b22f291 (diff) | |
| download | spark-5c8f4bd5fae539ab5fb992573d5357ed34e2f4d0.tar.gz spark-5c8f4bd5fae539ab5fb992573d5357ed34e2f4d0.tar.bz2 spark-5c8f4bd5fae539ab5fb992573d5357ed34e2f4d0.zip | |
[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.
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #5695 from tdas/SPARK-7138 and squashes the following commits:
a35cf7d [Tathagata Das] Fixed style.
a7a4cb9 [Tathagata Das] Added extra method to BlockGenerator.
Diffstat (limited to 'python')
0 files changed, 0 insertions, 0 deletions