diff options
author | Rishab Joshi <rishab.joshi@mongodb.com> | 2021-10-11 14:23:17 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-10-15 22:08:36 +0000 |
commit | 37104ac0e21fdffd29de16be74f4a35d4e1c865c (patch) | |
tree | 8fab578349c6581c4ad3ff6e6d8f1c82235dc96c /src/mongo/db/pipeline/document_source_change_stream_check_invalidate.h | |
parent | dad32a29132b9427a9d742f4f4d2ecf3bc3d830f (diff) | |
download | mongo-37104ac0e21fdffd29de16be74f4a35d4e1c865c.tar.gz |
SERVER-55659 Remove feature flag for Allow $changeStream to participate
in optimization.
Diffstat (limited to 'src/mongo/db/pipeline/document_source_change_stream_check_invalidate.h')
-rw-r--r-- | src/mongo/db/pipeline/document_source_change_stream_check_invalidate.h | 11 |
1 files changed, 2 insertions, 9 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream_check_invalidate.h b/src/mongo/db/pipeline/document_source_change_stream_check_invalidate.h index 30dc1b6eeda..166604c1d10 100644 --- a/src/mongo/db/pipeline/document_source_change_stream_check_invalidate.h +++ b/src/mongo/db/pipeline/document_source_change_stream_check_invalidate.h @@ -39,9 +39,7 @@ namespace mongo { * "invalidate" entry for commands that should invalidate the change stream (e.g. collection drop * for a single-collection change stream). It is not intended to be created by the user. */ -class DocumentSourceChangeStreamCheckInvalidate final - : public DocumentSource, - public ChangeStreamStageSerializationInterface { +class DocumentSourceChangeStreamCheckInvalidate final : public DocumentSource { public: static constexpr StringData kStageName = "$_internalChangeStreamCheckInvalidate"_sd; @@ -66,9 +64,7 @@ public: return boost::none; } - Value serialize(boost::optional<ExplainOptions::Verbosity> explain) const final { - return ChangeStreamStageSerializationInterface::serializeToValue(explain); - } + Value serialize(boost::optional<ExplainOptions::Verbosity> explain) const final; static boost::intrusive_ptr<DocumentSourceChangeStreamCheckInvalidate> createFromBson( BSONElement spec, const boost::intrusive_ptr<ExpressionContext>& expCtx); @@ -91,9 +87,6 @@ private: GetNextResult doGetNext() final; - Value serializeLegacy(boost::optional<ExplainOptions::Verbosity> explain) const final; - Value serializeLatest(boost::optional<ExplainOptions::Verbosity> explain) const final; - boost::optional<ResumeTokenData> _startAfterInvalidate; boost::optional<Document> _queuedInvalidate; boost::optional<ChangeStreamInvalidationInfo> _queuedException; |