[SPARK-27730] Add support for removeAllKeys

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 2.3.3
• Fix Version/s: 3.0.0
• Component/s: Spark Core
• Assignee: Unassigned
• Reporter: David C Navas
• Created: 15/May/19 18:38
• Updated: 24/Jul/19 05:48
• Resolved: 21/May/19 18:11

Description

After a false start as described in attached, I implement a removeAllKeys call to KVStore that is capable of deleting all keys that match a particular class' index.  The implementation in LevelDB performs a delete based on each key, as elements in LevelDB are indexed, and the implementation in InMemoryStore performs a scan and conditional remove, as elements in InMemoryStore are not indexed.

 

Issue Links

• duplicates: SPARK-27726 Performance of InMemoryStore suffers under load