GreaterThan
ではありません それはあなたの問題を引き起こしています、それはフィルターがネストされたフィールドにあるという事実です。 doc_type
のフィルター ネストされていないため、機能します。これは明らかに、Mongoコネクタではなく、SparkのCatalystエンジンの問題です。これは、Parquetなどの述語のプッシュダウンにも影響します。
詳細については、SparkJiraの次の説明を参照してください。
GreaterThan
ではありません それはあなたの問題を引き起こしています、それはフィルターがネストされたフィールドにあるという事実です。 doc_type
のフィルター ネストされていないため、機能します。これは明らかに、Mongoコネクタではなく、SparkのCatalystエンジンの問題です。これは、Parquetなどの述語のプッシュダウンにも影響します。
詳細については、SparkJiraの次の説明を参照してください。