diff options
author | Iulian Dragos <jaguarul@gmail.com> | 2015-07-31 12:04:03 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-07-31 12:04:03 -0700 |
commit | 0a1d2ca42c8b31d6b0e70163795f0185d4622f87 (patch) | |
tree | d453ae5039eeccfba70958dadab2c98766126ede /python/pyspark/streaming/kinesis.py | |
parent | e8bdcdeabb2df139a656f86686cdb53c891b1f4b (diff) | |
download | spark-0a1d2ca42c8b31d6b0e70163795f0185d4622f87.tar.gz spark-0a1d2ca42c8b31d6b0e70163795f0185d4622f87.tar.bz2 spark-0a1d2ca42c8b31d6b0e70163795f0185d4622f87.zip |
[SPARK-8979] Add a PID based rate estimator
Based on #7600
/cc tdas
Author: Iulian Dragos <jaguarul@gmail.com>
Author: François Garillot <francois@garillot.net>
Closes #7648 from dragos/topic/streaming-bp/pid and squashes the following commits:
aa5b097 [Iulian Dragos] Add more comments, made all PID constant parameters positive, a couple more tests.
93b74f8 [Iulian Dragos] Better explanation of historicalError.
7975b0c [Iulian Dragos] Add configuration for PID.
26cfd78 [Iulian Dragos] A couple of variable renames.
d0bdf7c [Iulian Dragos] Update to latest version of the code, various style and name improvements.
d58b845 [François Garillot] [SPARK-8979][Streaming] Implements a PIDRateEstimator
Diffstat (limited to 'python/pyspark/streaming/kinesis.py')
0 files changed, 0 insertions, 0 deletions