Tell us about the problem you're trying to solve

We have a spec cache CachingSchedulerJobClient which contains a method invalidateCache which invalidates the whole cache wholesale. It would be nice to have a method evictFromCache which invalidates a specific cache entry to allow invalidating portions of the cache.

Additionally, it would be good if we could reuse the ReplaceOneModel and UpdateOneModel from the sink signatures,
where currently they are expecting a Tuple2[Bson, Bson] for the updates, and a Tuple2[Bson, Document], we could create a case class respectively to wrap those values in a more idiomatic way.
i.e

case class ReplaceOne[Doc](filter: Bson, replacement: Doc) {
 def to

I am working with an Odata API interface which presents timestamp values such as lastModified in a format similar to `//Date(1530144000000+0530)/. Would it be possible to get such date formats supported. If this is something that could be supported I'd be happy to contribute this sort of functionality, a steer in the right direction would certainly be appreciated.

Current behavior:
JSONStream or NormalizedJSONStream are randomly defined in readers as outputs.

Expected behavior:
As a user, I want to have non-normalized streams (JSONStream for example) in the readers because I want to normalize them with the --normalize-keys parameter at the entrypoint.py level if needed.