spark-instrumented-optimizer/python/pyspark/streaming
Burak Yavuz 302d68de87 [SPARK-12058][STREAMING][KINESIS][TESTS] fix Kinesis python tests
Python tests require access to the `KinesisTestUtils` file. When this file exists under src/test, python can't access it, since it is not available in the assembly jar.

However, if we move KinesisTestUtils to src/main, we need to add the KinesisProducerLibrary as a dependency. In order to avoid this, I moved KinesisTestUtils to src/main, and extended it with ExtendedKinesisTestUtils which is under src/test that adds support for the KPL.

cc zsxwing tdas

Author: Burak Yavuz <brkyvz@gmail.com>

Closes #10050 from brkyvz/kinesis-py.
2015-12-04 12:08:42 -08:00
..
__init__.py [SPARK-6328][PYTHON] Python API for StreamingListener 2015-11-16 11:29:27 -08:00
context.py [SPARK-6328][PYTHON] Python API for StreamingListener 2015-11-16 11:29:27 -08:00
dstream.py [SPARK-11812][PYSPARK] invFunc=None works properly with python's reduceByKeyAndWindow 2015-11-19 13:57:23 -08:00
flume.py [SPARK-10447][SPARK-3842][PYSPARK] upgrade pyspark to py4j0.9 2015-10-20 10:52:49 -07:00
kafka.py [SPARK-9065][STREAMING][PYSPARK] Add MessageHandler for Kafka Python API 2015-11-17 16:57:52 -08:00
kinesis.py [SPARK-10447][SPARK-3842][PYSPARK] upgrade pyspark to py4j0.9 2015-10-20 10:52:49 -07:00
listener.py [SPARK-6328][PYTHON] Python API for StreamingListener 2015-11-16 11:29:27 -08:00
mqtt.py [SPARK-10447][SPARK-3842][PYSPARK] upgrade pyspark to py4j0.9 2015-10-20 10:52:49 -07:00
tests.py [SPARK-12058][STREAMING][KINESIS][TESTS] fix Kinesis python tests 2015-12-04 12:08:42 -08:00
util.py [SPARK-12002][STREAMING][PYSPARK] Fix python direct stream checkpoint recovery issue 2015-12-01 15:26:10 -08:00