Added bypassDocumentValidation setting to async MapReduceIterable

JAVA-1985

Author: rozza

driver-async/src/main/com/mongodb/async/client/MapReduceIterable.java

@@ -160,6 +160,19 @@ public interface MapReduceIterable<TResult> extends MongoIterable<TResult> {
      */
     MapReduceIterable<TResult> batchSize(int batchSize);
 
+    /**
+     * Sets the bypass document level validation flag.
+     *
+     * <p>Note: This only applies when an $out stage is specified</p>.
+     *
+     * @param bypassDocumentValidation If true, allows the write to opt-out of document level validation.
+     * @return this
+     * @since 3.2
+     * @mongodb.driver.manual reference/command/mapReduce mapReduce
+     * @mongodb.server.release 3.2
+     */
+    MapReduceIterable<TResult> bypassDocumentValidation(Boolean bypassDocumentValidation);
+
     /**
      * Aggregates documents to a collection according to the specified map-reduce function with the given options, which must specify a
      * non-inline result.

driver-async/src/main/com/mongodb/async/client/MapReduceIterableImpl.java

@@ -67,6 +67,7 @@ class MapReduceIterableImpl<TDocument, TResult> implements MapReduceIterable<TRe
     private boolean sharded;
     private boolean nonAtomic;
     private int batchSize;
+    private Boolean bypassDocumentValidation;
 
     MapReduceIterableImpl(final MongoNamespace namespace, final Class<TDocument> documentClass, final Class<TResult> resultClass,
                           final CodecRegistry codecRegistry, final ReadPreference readPreference, final ReadConcern readConcern,
@@ -168,6 +169,13 @@ public MapReduceIterable<TResult> batchSize(final int batchSize) {
         return this;
     }
 
+
+    @Override
+    public MapReduceIterable<TResult> bypassDocumentValidation(final Boolean bypassDocumentValidation) {
+        this.bypassDocumentValidation = bypassDocumentValidation;
+        return this;
+    }
+
     @Override
     public void toCollection(final SingleResultCallback<Void> callback) {
         notNull("callback", callback);
@@ -257,7 +265,8 @@ private MapReduceToCollectionOperation createMapReduceToCollectionOperation() {
                 .action(action.getValue())
                 .nonAtomic(nonAtomic)
                 .sharded(sharded)
-                .databaseName(databaseName);
+                .databaseName(databaseName)
+                .bypassDocumentValidation(bypassDocumentValidation);
 
         if (finalizeFunction != null) {
             operation.finalizeFunction(new BsonJavaScript(finalizeFunction));

driver-async/src/test/unit/com/mongodb/async/client/MapReduceIterableSpecification.groovy

@@ -128,6 +128,7 @@ class MapReduceIterableSpecification extends Specification {
                 .action(MapReduceAction.MERGE)
                 .sharded(true)
                 .jsMode(true)
+                .bypassDocumentValidation(true)
         mapReduceIterable.into([]) { result, t -> }
 
         def operation = executor.getWriteOperation() as MapReduceToCollectionOperation
@@ -145,6 +146,7 @@ class MapReduceIterableSpecification extends Specification {
                 .action(MapReduceAction.MERGE.getValue())
                 .jsMode(true)
                 .sharded(true)
+                .bypassDocumentValidation(true)
 
         then: 'should use the overrides'
         expect operation, isTheSameAs(expectedOperation)