Chaim created BEAM-6134:
---------------------------

             Summary: MongoDbIO add support for projection
                 Key: BEAM-6134
                 URL: https://issues.apache.org/jira/browse/BEAM-6134
             Project: Beam
          Issue Type: Improvement
          Components: io-java-mongodb
    Affects Versions: 2.8.0
            Reporter: Chaim
            Assignee: Jean-Baptiste Onofré
             Fix For: 2.9.0


MongoDbIO.read should have support for Projection, so that we can limit the 
document size that is retrieved, for example:

 

pipeline.apply(tableName + " read", MongoDbIO.read()
 .withUri("mongodb://" + srcMongodbManagment.getMongodbConnection())
 .withProjection("time")
 .withDatabase(options.getDBName())
 .withKeepAlive(true)
 .withCollection(tableName))

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to