Package org.mongojack.internal.util

Class MapReduceIterableDecorator<TResult>

java.lang.Object

org.mongojack.internal.util.MapReduceIterableDecorator<TResult>

Type Parameters:

TResult - the type this iterable produces

All Implemented Interfaces:

com.mongodb.client.MapReduceIterable<TResult>, com.mongodb.client.MongoIterable<TResult>, Iterable<TResult>

public class MapReduceIterableDecorator<TResult>
extends Object
implements com.mongodb.client.MapReduceIterable<TResult>

Wraps a MapReduceIterable so we can map the incoming filters.

Constructor Summary

Constructors

Constructor	Description
MapReduceIterableDecorator(com.mongodb.client.MapReduceIterable<TResult> delegate, com.fasterxml.jackson.databind.ObjectMapper objectMapper, com.fasterxml.jackson.databind.JavaType type, JacksonCodecRegistry codecRegistry, SerializationOptions serializationOptions)

Method Summary

Modifier and Type	Method	Description
com.mongodb.client.MapReduceIterable<TResult>	action(com.mongodb.client.model.MapReduceAction action)
com.mongodb.client.MapReduceIterable<TResult>	batchSize(int batchSize)
com.mongodb.client.MapReduceIterable<TResult>	bypassDocumentValidation(Boolean bypassDocumentValidation)
com.mongodb.client.MapReduceIterable<TResult>	collation(com.mongodb.client.model.Collation collation)
com.mongodb.client.MapReduceIterable<TResult>	collectionName(String collectionName)
com.mongodb.client.MongoCursor<TResult>	cursor()
com.mongodb.client.MapReduceIterable<TResult>	databaseName(String databaseName)
com.mongodb.client.MapReduceIterable<TResult>	filter(org.bson.conversions.Bson filter)
com.mongodb.client.MapReduceIterable<TResult>	finalizeFunction(String finalizeFunction)
TResult	first()
void	forEach(Consumer<? super TResult> action)
<A extends Collection<? super TResult>> A	into(A target)
com.mongodb.client.MongoCursor<TResult>	iterator()
com.mongodb.client.MapReduceIterable<TResult>	jsMode(boolean jsMode)
com.mongodb.client.MapReduceIterable<TResult>	limit(int limit)
<U> com.mongodb.client.MongoIterable<U>	map(com.mongodb.Function<TResult,U> mapper)
com.mongodb.client.MapReduceIterable<TResult>	maxTime(long maxTime, TimeUnit timeUnit)
com.mongodb.client.MapReduceIterable<TResult>	scope(org.bson.conversions.Bson scope)
com.mongodb.client.MapReduceIterable<TResult>	sort(org.bson.conversions.Bson sort)
Spliterator<TResult>	spliterator()
void	toCollection()
com.mongodb.client.MapReduceIterable<TResult>	verbose(boolean verbose)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapReduceIterableDecorator

public MapReduceIterableDecorator(com.mongodb.client.MapReduceIterable<TResult> delegate,
                                  com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                  com.fasterxml.jackson.databind.JavaType type,
                                  JacksonCodecRegistry codecRegistry,
                                  SerializationOptions serializationOptions)

Method Detail

toCollection

public void toCollection()

Specified by:

toCollection in interface com.mongodb.client.MapReduceIterable<TResult>

collectionName

public com.mongodb.client.MapReduceIterable<TResult> collectionName(String collectionName)

Specified by:

collectionName in interface com.mongodb.client.MapReduceIterable<TResult>

finalizeFunction

public com.mongodb.client.MapReduceIterable<TResult> finalizeFunction(String finalizeFunction)

Specified by:

finalizeFunction in interface com.mongodb.client.MapReduceIterable<TResult>

scope

public com.mongodb.client.MapReduceIterable<TResult> scope(org.bson.conversions.Bson scope)

Specified by:

scope in interface com.mongodb.client.MapReduceIterable<TResult>

sort

public com.mongodb.client.MapReduceIterable<TResult> sort(org.bson.conversions.Bson sort)

Specified by:

sort in interface com.mongodb.client.MapReduceIterable<TResult>

filter

public com.mongodb.client.MapReduceIterable<TResult> filter(org.bson.conversions.Bson filter)

Specified by:

filter in interface com.mongodb.client.MapReduceIterable<TResult>

limit

public com.mongodb.client.MapReduceIterable<TResult> limit(int limit)

Specified by:

limit in interface com.mongodb.client.MapReduceIterable<TResult>

jsMode

public com.mongodb.client.MapReduceIterable<TResult> jsMode(boolean jsMode)

Specified by:

jsMode in interface com.mongodb.client.MapReduceIterable<TResult>

verbose

public com.mongodb.client.MapReduceIterable<TResult> verbose(boolean verbose)

Specified by:

verbose in interface com.mongodb.client.MapReduceIterable<TResult>

maxTime

public com.mongodb.client.MapReduceIterable<TResult> maxTime(long maxTime,
                                                             TimeUnit timeUnit)

Specified by:

maxTime in interface com.mongodb.client.MapReduceIterable<TResult>

action

public com.mongodb.client.MapReduceIterable<TResult> action(com.mongodb.client.model.MapReduceAction action)

Specified by:

action in interface com.mongodb.client.MapReduceIterable<TResult>

databaseName

public com.mongodb.client.MapReduceIterable<TResult> databaseName(String databaseName)

Specified by:

databaseName in interface com.mongodb.client.MapReduceIterable<TResult>

batchSize

public com.mongodb.client.MapReduceIterable<TResult> batchSize(int batchSize)

Specified by:

batchSize in interface com.mongodb.client.MapReduceIterable<TResult>

Specified by:

batchSize in interface com.mongodb.client.MongoIterable<TResult>

bypassDocumentValidation

public com.mongodb.client.MapReduceIterable<TResult> bypassDocumentValidation(Boolean bypassDocumentValidation)

Specified by:

bypassDocumentValidation in interface com.mongodb.client.MapReduceIterable<TResult>

collation

public com.mongodb.client.MapReduceIterable<TResult> collation(com.mongodb.client.model.Collation collation)

Specified by:

collation in interface com.mongodb.client.MapReduceIterable<TResult>

iterator

public com.mongodb.client.MongoCursor<TResult> iterator()

Specified by:

iterator in interface Iterable<TResult>

Specified by:

iterator in interface com.mongodb.client.MongoIterable<TResult>

cursor

public com.mongodb.client.MongoCursor<TResult> cursor()

Specified by:

cursor in interface com.mongodb.client.MongoIterable<TResult>

first

@Nullable
public TResult first()

Specified by:

first in interface com.mongodb.client.MongoIterable<TResult>

map

public <U> com.mongodb.client.MongoIterable<U> map(com.mongodb.Function<TResult,U> mapper)

Specified by:

map in interface com.mongodb.client.MongoIterable<TResult>

into

public <A extends Collection<? super TResult>> A into(A target)

Specified by:

into in interface com.mongodb.client.MongoIterable<TResult>

forEach

public void forEach(Consumer<? super TResult> action)

Specified by:

forEach in interface Iterable<TResult>

spliterator

public Spliterator<TResult> spliterator()

Specified by:

spliterator in interface Iterable<TResult>