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
All Methods Instance Methods Concrete Methods 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>>
Ainto(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)
-
-
-
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 interfacecom.mongodb.client.MapReduceIterable<TResult>
-
collectionName
public com.mongodb.client.MapReduceIterable<TResult> collectionName(String collectionName)
- Specified by:
collectionName
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
finalizeFunction
public com.mongodb.client.MapReduceIterable<TResult> finalizeFunction(String finalizeFunction)
- Specified by:
finalizeFunction
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
scope
public com.mongodb.client.MapReduceIterable<TResult> scope(org.bson.conversions.Bson scope)
- Specified by:
scope
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
sort
public com.mongodb.client.MapReduceIterable<TResult> sort(org.bson.conversions.Bson sort)
- Specified by:
sort
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
filter
public com.mongodb.client.MapReduceIterable<TResult> filter(org.bson.conversions.Bson filter)
- Specified by:
filter
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
limit
public com.mongodb.client.MapReduceIterable<TResult> limit(int limit)
- Specified by:
limit
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
jsMode
public com.mongodb.client.MapReduceIterable<TResult> jsMode(boolean jsMode)
- Specified by:
jsMode
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
verbose
public com.mongodb.client.MapReduceIterable<TResult> verbose(boolean verbose)
- Specified by:
verbose
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
maxTime
public com.mongodb.client.MapReduceIterable<TResult> maxTime(long maxTime, TimeUnit timeUnit)
- Specified by:
maxTime
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
action
public com.mongodb.client.MapReduceIterable<TResult> action(com.mongodb.client.model.MapReduceAction action)
- Specified by:
action
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
databaseName
public com.mongodb.client.MapReduceIterable<TResult> databaseName(String databaseName)
- Specified by:
databaseName
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
batchSize
public com.mongodb.client.MapReduceIterable<TResult> batchSize(int batchSize)
-
bypassDocumentValidation
public com.mongodb.client.MapReduceIterable<TResult> bypassDocumentValidation(Boolean bypassDocumentValidation)
- Specified by:
bypassDocumentValidation
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
collation
public com.mongodb.client.MapReduceIterable<TResult> collation(com.mongodb.client.model.Collation collation)
- Specified by:
collation
in interfacecom.mongodb.client.MapReduceIterable<TResult>
-
iterator
public com.mongodb.client.MongoCursor<TResult> iterator()
-
cursor
public com.mongodb.client.MongoCursor<TResult> cursor()
- Specified by:
cursor
in interfacecom.mongodb.client.MongoIterable<TResult>
-
first
@Nullable public TResult first()
- Specified by:
first
in interfacecom.mongodb.client.MongoIterable<TResult>
-
map
public <U> com.mongodb.client.MongoIterable<U> map(com.mongodb.Function<TResult,U> mapper)
- Specified by:
map
in interfacecom.mongodb.client.MongoIterable<TResult>
-
into
public <A extends Collection<? super TResult>> A into(A target)
- Specified by:
into
in interfacecom.mongodb.client.MongoIterable<TResult>
-
spliterator
public Spliterator<TResult> spliterator()
- Specified by:
spliterator
in interfaceIterable<TResult>
-
-