Corvin Deboeser created BEAM-8887:
-------------------------------------

             Summary: Allow for aggregate queries in Python MongoDBIO Read
                 Key: BEAM-8887
                 URL: https://issues.apache.org/jira/browse/BEAM-8887
             Project: Beam
          Issue Type: New Feature
          Components: io-py-mongodb
            Reporter: Corvin Deboeser
            Assignee: Yichi Zhang


Currently, MongoDBIO in the Python SDK only allows to use basic projections and 
filters (db.x.find(..)), but not aggregations (db.x.aggregate(..)).

As a pipeline creator, I would like to be able to use aggregations and more 
complicated queries as input to a beam pipeline. Example use cases are sampling 
data ($sample), joining foreign data ($lookup), 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to