You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Corvin Deboeser (Jira)" <ji...@apache.org> on 2019/12/04 03:38:00 UTC

[jira] [Created] (BEAM-8887) Allow for aggregate queries in Python MongoDBIO Read

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)