[BEAM-6134] MongoDbIO add support for projection

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.8.0
• Fix Version/s: 2.10.0
• Component/s: io-java-mongodb
• Labels: easyfix
• Assignee: Jean-Baptiste Onofré
• Reporter: Chaim
• Created: 27/Nov/18 15:02
• Updated: 16/May/20 13:52
• Resolved: 28/Nov/18 13:44

Description

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))

 

Issue Links

• relates to: BEAM-3346 Add projections to MongoDb IO
• links to: GitHub Pull Request #7148