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)