Uploaded image for project: 'Drivers'
  1. Drivers
  2. DRIVERS-436

Add pipeline stage to ChangeStreams example for Docs

XMLWordPrintableJSON

    • Type: Icon: Task Task
    • Resolution: Fixed
    • Priority: Icon: Major - P3 Major - P3
    • None
    • Component/s: Docs Examples
    • None

      In a previous ticket DRIVERS-414, included Example 1-3. This ticket is to add the Example 4 sections to the existing example : 

      // Start Changestream Example 1

MongoCursor<Document> cursor = inventory.watch().iterator();
Document next = cursor.next();

// End Changestream Example 1

      // Start Changestream Example 2

MongoCursor<Document> cursor = 
inventory.watch().fullDocument(FullDocument.UPDATE_LOOKUP).iterator();
Document next = cursor.next();

// End Changestream Example 2

      // Start Changestream Example 3

Document resumeToken = next.get("_id", Document.class);
MongoCursor<Document> cursor = inventory.watch().resumeAfter(resumeToken).iterator();
cursor.next();

// End Changestream Example 3

      // Start Changestream Example 4

List<Bson> pipeline = singletonList(Aggregates.match(Filters.or(
   Document.parse("{'fullDocument.username': 'alice'}"),
   Filters.in("operationType", asList("delete")))));

// End Changestream Example 4

            Assignee:
            Unassigned Unassigned
            Reporter:
            rathi.gnanasekaran Rathi Gnanasekaran
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

              Created:
              Updated:
              Resolved: