/
githubmirror
/
spark
ОбзорДокументацияВойти
/
githubmirror
/
spark
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
ДокументацияПоддержка
Политика конфиденциальностиПользовательское соглашениеПолитика использования «cookies»Согласие субъекта персональных данных
2026 ©
spark/
.../tests/streaming/
..
KAFKA_TESTING.md

[SPARK-58015][INFRA] Move dependency list from requirements.txt to pyproject.toml

месяц назад
__init__.py

[SPARK-40789][PYTHON][TESTS] Separate tests under pyspark.sql.tests

4 года назад
kafka_utils.py

[SPARK-55306] Add ability to run Kafka tests in Python

4 месяца назад
test_streaming.py

[SPARK-58135][PYTHON] Consolidate VALUE_NOT_TRUE into VALUE_NOT_ALLOWED

месяц назад
test_streaming_foreach.py

[SPARK-54599][PYTHON] Refactor PythonException so it can take errorClass with sqlstate

6 месяцев назад
test_streaming_foreach_batch.py

[SPARK-54599][PYTHON] Refactor PythonException so it can take errorClass with sqlstate

6 месяцев назад
test_streaming_kafka_rtm.py

[SPARK-56403] Refactor kafka test so it's skipped when dependency is not available

4 месяца назад
test_streaming_listener.py

[SPARK-56537][SS] Reset per-batch time fields and customMetrics on no batch trigger progress event

3 месяца назад
test_streaming_offline_state_repartition.py

[SPARK-55986][PYTHON] Upgrade black to 26.3.1

5 месяцев назад