Upserts, Deletes And Incremental Processing on Big Data.
bigdata
stream-processing
data-integration
datalake
apachespark
hudi
apachehudi
incremental-processing
apacheflink
-
Updated
Feb 24, 2021 - Java
Tell us about the problem you're trying to solve
We have a spec cache
CachingSchedulerJobClientwhich contains a methodinvalidateCachewhich invalidates the whole cache wholesale. It would be nice to have a methodevictFromCachewhich invalidates a specific cache entry to allow invalidating portions of the cache.