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

[SPARK-52228][SS][PYSPARK] Construct the benchmark purposed TWS state server with in-memory state impls and the benchmark code in python

год назад
proto

[SPARK-56018][PYTHON] Use ruff as formatter

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

[SPARK-55480][PYTHON] Remove all unused noqa for ruff

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

[SPARK-55304][SS][PYTHON] Introduce support of Admission Control and Trigger.AvailableNow in Python data source - streaming reader

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

[SPARK-56018][PYTHON] Use ruff as formatter

5 месяцев назад
listener.py

[SPARK-58244][PYTHON] Remove type: ignore[name-defined] for DataFrame.plot and streaming _test() in pyspark.sql

19 дней назад
map_state_client.py

[SPARK-56018][PYTHON] Use ruff as formatter

5 месяцев назад
python_streaming_source_runner.py

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

5 месяцев назад
query.py

[SPARK-58244][PYTHON] Remove type: ignore[name-defined] for DataFrame.plot and streaming _test() in pyspark.sql

19 дней назад
readwriter.py

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

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

[SPARK-56179][PYTHON] Consolidate error classes for type mismatch - part 2

5 месяцев назад
stateful_processor.py

[SPARK-51814][SS][PYTHON] Introduce a new API `transformWithState` in PySpark

год назад
stateful_processor_api_client.py

[SPARK-57760][SS][PYTHON][FOLLOWUP] Fix mypy union-attr error in _normalize_state_value

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

[SPARK-52333][SS][PYTHON] Squeeze the protocol of retrieving timers for transformWithState in PySpark

год назад
transform_with_state_driver_worker.py

[SPARK-55665][PYTHON] Unify how workers establish connection with the executor

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

[SPARK-54805][SS][PYTHON] Implement TwsTester in PySpark

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

[SPARK-56018][PYTHON] Use ruff as formatter

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