Sean Owen c2d0d700b5 [SPARK-26640][CORE][ML][SQL][STREAMING][PYSPARK] Code cleanup from lgtm.com analysis ... ## What changes were proposed in this pull request? Misc code cleanup from lgtm.com analysis. See comments below for details. ## How was this patch tested? Existing tests. Closes #23571 from srowen/SPARK-26640. Lead-authored-by: Sean Owen <sean.owen@databricks.com> Co-authored-by: Hyukjin Kwon <gurwls223@apache.org> Co-authored-by: Sean Owen <srowen@gmail.com> Signed-off-by: Sean Owen <sean.owen@databricks.com>		2019-01-17 19:40:39 -06:00
..
tests	[SPARK-26035][PYTHON] Break large streaming/tests.py files into smaller files	2018-11-16 07:58:09 +08:00
__init__.py	[SPARK-6328][PYTHON] Python API for StreamingListener	2015-11-16 11:29:27 -08:00
context.py	[SPARK-26640][CORE][ML][SQL][STREAMING][PYSPARK] Code cleanup from lgtm.com analysis	2019-01-17 19:40:39 -06:00
dstream.py	[SPARK-25705][BUILD][STREAMING][TEST-MAVEN] Remove Kafka 0.8 integration	2018-10-16 09:10:24 -05:00
kinesis.py	[SPARK-26640][CORE][ML][SQL][STREAMING][PYSPARK] Code cleanup from lgtm.com analysis	2019-01-17 19:40:39 -06:00
listener.py	[SPARK-24014][PYSPARK] Add onStreamingStarted method to StreamingListener	2018-04-19 10:00:57 +08:00
util.py	[SPARK-17756][PYTHON][STREAMING] Workaround to avoid return type mismatch in PythonTransformFunction	2018-06-09 01:27:51 +07:00