can you use something like this:
It will be a SparkConf setting so “spark.mongodb.read.aggregation.pipeline”:“[{”$match": {“operationType”: “insert”}]’ for example
ref: MongoDB Connector for Spark V10 and Change Stream - #11 by khang_pham
can you use something like this:
It will be a SparkConf setting so “spark.mongodb.read.aggregation.pipeline”:“[{”$match": {“operationType”: “insert”}]’ for example
ref: MongoDB Connector for Spark V10 and Change Stream - #11 by khang_pham