Skip to content

Pull requests: tdas/spark

New pull request New
Clear current search query, filters, and sorts
3 Open 31 Closed
3 Open 31 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

MapGroupsWithState, and FlatMapGroupsWithState
#34 by tdas was closed Jan 31, 2017 Loading…
1
Streaming df kinesis updated
#33 by zsxwing was closed Mar 24, 2016 Loading…
Minor fixes
#32 by lw-lin was closed May 10, 2016 Loading…
Add Kinesis Source
#31 by zsxwing was merged Feb 24, 2016 Loading…
35
Add Kinesis Source
#30 by zsxwing was closed Feb 19, 2016 Loading…
1
Fix ClassCastException when requesting receiver info
#29 by andrewor14 was merged Dec 4, 2015 Loading…
Minor edits in Streaming Programming Guide
#26 by JoshRosen was merged Dec 10, 2014 Loading…
8
Fix minor formatting, use match-case in getPreferredLocations
#24 by harishreedharan was closed Nov 12, 2014 Loading…
1
Reorg code that fetches blocks from HDFS
#23 by harishreedharan was closed Oct 29, 2014 Loading…
Shutdown spark context after tests. Formatting/minor fixes
#22 by harishreedharan was merged Oct 27, 2014 Loading…
Make sure getBlockLocations uses offset and length to find the blocks on...
#21 by harishreedharan was merged Oct 25, 2014 Loading…
Directory deletion should not fail tests
#20 by harishreedharan was merged Oct 23, 2014 Loading…
Sort listed files by name. Use local files for WAL tests.
#19 by harishreedharan was merged Oct 23, 2014 Loading…
2
Fix tests to not ignore ordering and also assert all data is present
#18 by harishreedharan was merged Oct 23, 2014 Loading…
9
Use Minicluster for WAL tests.
#17 by harishreedharan was merged Oct 22, 2014 Loading…
12
Using MiniDFSCluster for all tests where data is read and written using WALReader/Writer.
#16 by harishreedharan was closed Oct 22, 2014 Loading…
1
Initial implementation of HDFSBackedBlockRDD.
#15 by harishreedharan was merged Oct 9, 2014 Loading…
56
Driver HA support using WriteAheadLog
#14 by tdas was closed Nov 11, 2014 Loading…
Fix the way we decide if hasNext is true or not in WALReader. Unit tests...
#13 by harishreedharan was merged Oct 4, 2014 Loading…
8
Initial HDFS Readers and Writers implementation.
#12 by harishreedharan was merged Oct 2, 2014 Loading…
29
[PySpark][Streaming][SPARK-2377] Python API for Spark Streaming
#11 by giwa was closed Sep 26, 2014 Loading…
10
Python API for Spark Streaming
#10 by giwa was closed Aug 21, 2014 Loading…
28
Merge with master
#9 by andrewor14 was merged Apr 12, 2014 Loading…
Address Patrick's comments
#8 by andrewor14 was merged Apr 11, 2014 Loading…
Address Patrick's comments
#7 by andrewor14 was closed Apr 11, 2014 Loading…
ProTip! Filter pull requests by the default branch with base:master.