Morph MORPH
SIGN IN SIGN UP
apache / spark UNCLAIMED

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

0 0 322 Scala

COMMITS

/ python/pyspark/sql/streaming/stateful_processor_api_client.py
master
April 2, 2026
Y
[SPARK-56222][PYTHON] Create ArrowStreamGroupSerializer and ArrowStreamCoGroupSerializer
Yicong Huang committed
25e85b2
March 19, 2026
T
[SPARK-56018][PYTHON] Use ruff as formatter
Tian Gao committed
eac3fe3
December 11, 2025
Z
[SPARK-51920][SS][PYTHON] Fix type handling of namedTuple for transfromWithState
zeruibao committed
ac5fce4
August 18, 2025
Z
[SPARK-51920][SS][PYTHON] Fix composite/nested type in value state for python TWS
zeruibao committed
9e06a50
May 29, 2025
J
[SPARK-52333][SS][PYTHON] Squeeze the protocol of retrieving timers for transformWithState in PySpark
Jungtaek Lim committed
3159416
May 15, 2025
J
[SPARK-52127][SS][PYTHON] Squeeze the protocol of MapState KEYS / VALUES / ITERATOR for transformWithState in PySpark
Jungtaek Lim committed
cea3ae4
April 25, 2025
J
[SPARK-51891][SS] Squeeze the protocol of ListState GET / PUT / APPENDLIST for transformWithState in PySpark
Jungtaek Lim committed
2c0fc70
April 15, 2025
H
[SPARK-51688][PYTHON] Use Unix Domain Socket between Python and JVM communication
Hyukjin Kwon committed
d3b6dd1
April 7, 2025
J
[SPARK-51690][SS] Change the protocol of ListState.put()/get()/appendList() from Arrow to simple custom protocol
Jungtaek Lim committed
418cfd1
March 31, 2025
J
[SPARK-51667][SS][PYTHON] Disable Nagle's algorithm (via TCP_NODELAY = true) in TWS + PySpark for python <-> state server
Jungtaek Lim committed
a760df7
January 15, 2025
R
[SPARK-50818][PYTHON] Replace `has_numpy` with `have_numpy`
Ruifeng Zheng committed
f223b8d
December 26, 2024
J
[SPARK-50578][PYTHON][SS] Add support for new version of state metadata for TransformWithStateInPandas
jingz-db committed
c920210
December 14, 2024
B
[SPARK-50540][PYTHON][SS] Fix string schema for StatefulProcessorHandle
bogao007 committed
5538d85
November 28, 2024
J
[SPARK-50194][SS][PYTHON] Integration of New Timer API and Initial State API with Timer
jingz-db committed
e6252d6
November 8, 2024
B
[SPARK-49899][PYTHON][SS] Support deleteIfExists for TransformWithStateInPandas
bogao007 committed
e4638c8
October 31, 2024
J
[SPARK-49513][SS] Add Support for timer in transformWithStateInPandas API
jingz-db committed
2ace2eb
October 21, 2024
B
[SPARK-49821][SS][PYTHON] Implement MapState and TTL support for TransformWithStateInPandas
bogao007 committed
c1198fa
October 6, 2024
B
[SPARK-49744][SS][PYTHON] Implement TTL support for ListState in TransformWithStateInPandas
bogao007 committed
06a8f6b
September 25, 2024
B
[SPARK-49463] Support ListState for TransformWithStateInPandas
bogao007 committed
828b1f9
September 5, 2024
C
[SPARK-49303][SS] Implement TTL for ValueState in transformWithStateInPandas API
Chaoqin Li committed
d75f550
August 15, 2024
B
[SPARK-48755][SS][PYTHON] transformWithState pyspark base implementation and ValueState support
bogao007 committed
def42d4