TResult
- The type of the result.public interface AggregateObservable<TResult> extends MongoObservable<TResult>
Modifier and Type | Method and Description |
---|---|
AggregateObservable<TResult> |
allowDiskUse(Boolean allowDiskUse)
Enables writing to temporary files.
|
AggregateObservable<TResult> |
bypassDocumentValidation(Boolean bypassDocumentValidation)
Sets the bypass document level validation flag.
|
AggregateObservable<TResult> |
collation(com.mongodb.client.model.Collation collation)
Sets the collation options
|
AggregateObservable<TResult> |
maxTime(long maxTime,
TimeUnit timeUnit)
Sets the maximum execution time on the server for this operation.
|
rx.Observable<Success> |
toCollection()
Aggregates documents according to the specified aggregation pipeline, which must end with a $out stage.
|
AggregateObservable<TResult> |
useCursor(Boolean useCursor)
Deprecated.
There is no replacement for this. Applications can assume that the driver will use a cursor for server versions
that support it (>= 2.6). The driver will ignore this as of MongoDB 3.6, which does not support inline results for the aggregate
command.
|
subscribe, toObservable
AggregateObservable<TResult> allowDiskUse(Boolean allowDiskUse)
allowDiskUse
- true if writing to temporary files is enabledAggregateObservable<TResult> maxTime(long maxTime, TimeUnit timeUnit)
maxTime
- the max timetimeUnit
- the time unit, which may not be null@Deprecated AggregateObservable<TResult> useCursor(Boolean useCursor)
useCursor
- whether the server should use a cursor to return resultsAggregateObservable<TResult> bypassDocumentValidation(Boolean bypassDocumentValidation)
Note: This only applies when an $out stage is specified
.bypassDocumentValidation
- If true, allows the write to opt-out of document level validation.rx.Observable<Success> toCollection()
AggregateObservable<TResult> collation(com.mongodb.client.model.Collation collation)
A null value represents the server default.
collation
- the collation options to use