Skip to content
  • Davies Liu's avatar
    0a7ef633
    [SPARK-3141] [PySpark] fix sortByKey() with take() · 0a7ef633
    Davies Liu authored
    Fix sortByKey() with take()
    
    The function `f` used in mapPartitions should always return an iterator.
    
    Author: Davies Liu <davies.liu@gmail.com>
    
    Closes #2045 from davies/fix_sortbykey and squashes the following commits:
    
    1160f59 [Davies Liu] fix sortByKey() with take()
    0a7ef633
    [SPARK-3141] [PySpark] fix sortByKey() with take()
    Davies Liu authored
    Fix sortByKey() with take()
    
    The function `f` used in mapPartitions should always return an iterator.
    
    Author: Davies Liu <davies.liu@gmail.com>
    
    Closes #2045 from davies/fix_sortbykey and squashes the following commits:
    
    1160f59 [Davies Liu] fix sortByKey() with take()
Loading