Ahmed El.Hussaini created BEAM-6241:
---------------------------------------
Summary: MongoDbIo - Add Limit and Aggregates Support
Key: BEAM-6241
URL: https://issues.apache.org/jira/browse/BEAM-6241
Project: Beam
Issue Type: Improvement
Components: io-java-mongodb
Affects Versions: 2.9.0
Reporter: Ahmed El.Hussaini
Assignee: Jean-Baptiste Onofré
Fix For: 2.10.0
h2. Adds Support to Limit Results
{code:java}
MongoDbIO.read()
.withUri("mongodb://localhost:" + port)
.withDatabase(DATABASE)
.withCollection(COLLECTION)
.withFilter("{\"scientist\":\"Einstein\"}")
.withLimit(5));{code}
h2. Adds Support to User Aggregates
{code:java}
List<BsonDocument> aggregates = new ArrayList<BsonDocument>();
aggregates.add(
new BsonDocument(
"$match",
new BsonDocument("country", new BsonDocument("$eq", new
BsonString("England")))));
PCollection<Document> output =
pipeline.apply(
MongoDbIO.read()
.withUri("mongodb://localhost:" + port)
.withDatabase(DATABASE)
.withCollection(COLLECTION)
.withAggregate(aggregates));
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
