Skip to content

Commit f8d8aad

Browse files
committed
CSHARP-2365: Deprecate parallelCollectionScan helpers
1 parent da0cff5 commit f8d8aad

File tree

4 files changed

+9
-1
lines changed

4 files changed

+9
-1
lines changed

README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,7 @@ Please see our [guidelines](CONTRIBUTING.md) for contributing to the driver.
8383
### Maintainers:
8484
* Vincent Kam [email protected]
8585
* Dmitry Lukyanov [email protected]
86+
* Katie Sadoff [email protected]
8687
* Robert Stam [email protected]
8788
* Craig Wilson [email protected]
8889

src/MongoDB.Driver.Core/Core/Operations/ParallelScanOperation.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ public class ParallelScanOperation<TDocument> : IReadOperation<IReadOnlyList<IAs
5252
/// <param name="numberOfCursors">The number of cursors.</param>
5353
/// <param name="serializer">The serializer.</param>
5454
/// <param name="messageEncoderSettings">The message encoder settings.</param>
55+
[Obsolete("ParallelScanOperation was deprecated in server version 4.1.")]
5556
public ParallelScanOperation(
5657
CollectionNamespace collectionNamespace,
5758
int numberOfCursors,

src/MongoDB.Driver.Legacy/MongoCollection.cs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1702,11 +1702,13 @@ private MapReduceResult MapReduce(IClientSessionHandle session, MapReduceArgs ar
17021702
/// <typeparam name="TDocument">The type of the document.</typeparam>
17031703
/// <param name="args">The args.</param>
17041704
/// <returns>Multiple enumerators, one for each cursor.</returns>
1705+
[Obsolete("ParallelScanAs was deprecated in server version 4.1.")]
17051706
public ReadOnlyCollection<IEnumerator<TDocument>> ParallelScanAs<TDocument>(ParallelScanArgs<TDocument> args)
17061707
{
17071708
return UsingImplicitSession(session => ParallelScanAs(session, args));
17081709
}
17091710

1711+
[Obsolete("ParallelScanAs was deprecated in server version 4.1.")]
17101712
private ReadOnlyCollection<IEnumerator<TDocument>> ParallelScanAs<TDocument>(IClientSessionHandle session, ParallelScanArgs<TDocument> args)
17111713
{
17121714
var batchSize = args.BatchSize;
@@ -1730,6 +1732,7 @@ private ReadOnlyCollection<IEnumerator<TDocument>> ParallelScanAs<TDocument>(ICl
17301732
/// <param name="documentType">Type of the document.</param>
17311733
/// <param name="args">The args.</param>
17321734
/// <returns>Multiple enumerators, one for each cursor.</returns>
1735+
[Obsolete("ParallelScanAs was deprecated in server version 4.1.")]
17331736
public ReadOnlyCollection<IEnumerator> ParallelScanAs(Type documentType, ParallelScanArgs args)
17341737
{
17351738
var parallelScanArgsDefinition = typeof(ParallelScanArgs<>);
@@ -2219,7 +2222,7 @@ private MongoCursor FindAs(Type documentType, IMongoQuery query, IBsonSerializer
22192222
#pragma warning disable 618
22202223
return MongoCursor.Create(documentType, this, query, _settings.ReadConcern, _settings.ReadPreference, serializer);
22212224
#pragma warning restore
2222-
2225+
22232226
}
22242227

22252228
private MongoCursor<TDocument> FindAs<TDocument>(IMongoQuery query, IBsonSerializer serializer)
@@ -2482,6 +2485,7 @@ public virtual IEnumerable<WriteConcernResult> InsertBatch(
24822485
/// </summary>
24832486
/// <param name="args">The args.</param>
24842487
/// <returns>Multiple enumerators, one for each cursor.</returns>
2488+
[Obsolete("ParallelScan was deprecated in server version 4.1.")]
24852489
public virtual ReadOnlyCollection<IEnumerator<TDefaultDocument>> ParallelScan(ParallelScanArgs<TDefaultDocument> args)
24862490
{
24872491
return ParallelScanAs<TDefaultDocument>(args);

tests/MongoDB.Driver.Legacy.Tests/MongoCollectionTests.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2949,11 +2949,13 @@ public void TestParallelScan()
29492949
_collection.Insert(new BsonDocument("_id", i));
29502950
}
29512951

2952+
#pragma warning disable 618
29522953
var enumerators = _collection.ParallelScanAs(typeof(BsonDocument), new ParallelScanArgs
29532954
{
29542955
BatchSize = 100,
29552956
NumberOfCursors = numberOfCursors
29562957
});
2958+
#pragma warning restore
29572959
Assert.True(enumerators.Count >= 1);
29582960

29592961
var ids = new List<int>();

0 commit comments

Comments
 (0)