diff options
| author | jerryshao <saisai.shao@intel.com> | 2015-05-01 17:46:06 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-05-01 17:46:06 -0700 |
| commit | b88c275e6ef6b17cd34d1c2c780b8959b41222c0 (patch) | |
| tree | d31993764bd60c261beff2b2e5306e76662b8600 /python/pyspark | |
| parent | ebc25a4ddfe07a67668217cec59893bc3b8cf730 (diff) | |
| download | spark-b88c275e6ef6b17cd34d1c2c780b8959b41222c0.tar.gz spark-b88c275e6ef6b17cd34d1c2c780b8959b41222c0.tar.bz2 spark-b88c275e6ef6b17cd34d1c2c780b8959b41222c0.zip | |
[SPARK-7112][Streaming][WIP] Add a InputInfoTracker to track all the input streams
Author: jerryshao <saisai.shao@intel.com>
Author: Saisai Shao <saisai.shao@intel.com>
Closes #5680 from jerryshao/SPARK-7111 and squashes the following commits:
339f854 [Saisai Shao] Add an end-to-end test
812bcaf [jerryshao] Continue address the comments
abd0036 [jerryshao] Address the comments
727264e [jerryshao] Fix comment typo
6682bef [jerryshao] Fix compile issue
8325787 [jerryshao] Fix rebase issue
17fa251 [jerryshao] Refactor to build InputInfoTracker
ee1b536 [jerryshao] Add DirectStreamTracker to track the direct streams
Diffstat (limited to 'python/pyspark')
0 files changed, 0 insertions, 0 deletions