Morph MORPH
SIGN IN SIGN UP
apache / spark UNCLAIMED

Apache Spark - A unified analytics engine for large-scale data processing

43071 0 180 Scala

COMMITS

/ python/pyspark/sql/streaming/python_streaming_source_runner.py
master
March 16, 2026
Y
[SPARK-55986][PYTHON] Upgrade black to 26.3.1
yangjie01 committed
cbcee8c
February 26, 2026
T
[SPARK-55665][PYTHON] Unify how workers establish connection with the executor
Tian Gao committed
191801b
February 7, 2026
J
[SPARK-55304][SS][PYTHON] Introduce support of Admission Control and Trigger.AvailableNow in Python data source - streaming reader
Jungtaek Lim committed
cbcc7f8
April 15, 2025
H
[SPARK-51688][PYTHON] Use Unix Domain Socket between Python and JVM communication
Hyukjin Kwon committed
d3b6dd1
March 7, 2025
A
[SPARK-50511][PYTHON][FOLLOWUP] Avoid wrapping streaming Python data source error messages
Allison Wang committed
c0ec84e
October 12, 2024
A
[SPARK-49930][SS] Ensure that socket updates are flushed on exception from the python worker
Anish Shrigondekar committed
3ecfe8e
July 24, 2024
H
[SPARK-48961][PYTHON] Make the parameter naming of `PySparkException` consistent with JVM
Haejoon Lee committed
090ad9f
June 21, 2024
A
[SPARK-48653][PYTHON] Fix invalid Python data source error class references
allisonwang-db committed
b0b02b2
June 17, 2024
C
[SPARK-47777] fix python streaming data source connect test
Chaoqin Li committed
9881e0a
May 20, 2024
C
[SPARK-48330][SS][PYTHON] Fix the python streaming data source timeout issue for large trigger interval
Chaoqin Li committed
0393ab4
April 30, 2024
C
[SPARK-47793][SS][PYTHON] Implement SimpleDataSourceStreamReader for python streaming data source
Chaoqin Li committed
c8c2492
April 25, 2024
H
Revert "[SPARK-45302][PYTHON] Remove PID communication between Pythonworkers when no demon is used"
Hyukjin Kwon committed
c6aaa18
April 4, 2024
H
[SPARK-47683][PYTHON][BUILD] Decouple PySpark core API to pyspark.core package
Hyukjin Kwon committed
678aeb7
March 27, 2024
C
[SPARK-47107][SS][PYTHON] Implement partition reader for python streaming data source
Chaoqin Li committed
e3e7135
March 12, 2024
C
[SPARK-46962][SS][PYTHON] Add interface for python streaming data source API and implement python worker to run python streaming data source
Chaoqin Li committed
f53dc08