|
1 | | -.. _streams-agg-pipeline-source: |
2 | 1 | .. _atlas-sp-agg-source: |
3 | 2 |
|
4 | 3 | ======================================== |
@@ -411,8 +410,12 @@ The ``$source`` stage takes a document with the following fields: |
411 | 410 | - document |
412 | 411 | - Optional |
413 | 412 | - Specifies an aggregation pipeline to filter change stream output |
414 | | - at the point of origin. This pipeline must conform to the parameters |
415 | | - described in :manual:`Modify Change Stream Output </changeStreams/#modify-change-stream-output>`. |
| 413 | + before passing it on for further processing. This pipeline must |
| 414 | + conform to the parameters described in |
| 415 | + :manual:`Modify Change Stream Output |
| 416 | + </changeStreams/#modify-change-stream-output>`. |
| 417 | + |
| 418 | + .. include:: /includes/atlas-stream-processing/change-event-time.rst |
416 | 419 |
|
417 | 420 | * - ``config.maxAwaitTimeMS`` |
418 | 421 | - integer |
@@ -603,6 +606,8 @@ The ``$source`` stage takes a document with the following fields: |
603 | 606 | at the point of origin. This pipeline must conform to the parameters |
604 | 607 | described in :manual:`Modify Change Stream Output </changeStreams/#modify-change-stream-output>`. |
605 | 608 |
|
| 609 | + .. include:: /includes/atlas-stream-processing/change-event-time.rst |
| 610 | + |
606 | 611 | * - ``config.maxAwaitTimeMS`` |
607 | 612 | - integer |
608 | 613 | - Optional |
@@ -779,6 +784,11 @@ The ``$source`` stage takes a document with the following fields: |
779 | 784 | at the point of origin. This pipeline must conform to the parameters |
780 | 785 | described in :ref:`<change-stream-modify-output>`. |
781 | 786 |
|
| 787 | + Note that {+atlas-sp+} expects to receive the ``wallTime`` and |
| 788 | + ``clusterTime`` fields from each ingested Change Event. To |
| 789 | + ensure proper processing of Change Stream data, do not modify |
| 790 | + these fields in ``$source.config.pipeline``. |
| 791 | + |
782 | 792 | * - ``config.maxAwaitTimeMS`` |
783 | 793 | - integer |
784 | 794 | - Optional |
|
0 commit comments