com.mongodb.rx.client

Interface AggregateObservable<TResult>

Type Parameters:

TResult - The type of the result.

All Superinterfaces:

MongoObservable<TResult>

public interface AggregateObservable<TResult>
extends MongoObservable<TResult>

Observable for aggregate.

Since:

1.0

Method Summary

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) Sets whether the server should use a cursor to return results.

Methods inherited from interface com.mongodb.rx.client.MongoObservable

subscribe, toObservable

Method Detail

allowDiskUse

AggregateObservable<TResult> allowDiskUse(Boolean allowDiskUse)

Enables writing to temporary files. A null value indicates that it's unspecified.

Parameters:

allowDiskUse - true if writing to temporary files is enabled

Returns:

this

MongoDB documentation

Aggregation

Since server release

2.6

maxTime

AggregateObservable<TResult> maxTime(long maxTime,
                                     TimeUnit timeUnit)

Sets the maximum execution time on the server for this operation.

Parameters:

maxTime - the max time

timeUnit - the time unit, which may not be null

Returns:

this

MongoDB documentation

Max Time

useCursor

AggregateObservable<TResult> useCursor(Boolean useCursor)

Sets whether the server should use a cursor to return results.

Parameters:

useCursor - whether the server should use a cursor to return results

Returns:

this

MongoDB documentation

Aggregation

Since server release

2.6

bypassDocumentValidation

AggregateObservable<TResult> bypassDocumentValidation(Boolean bypassDocumentValidation)

Sets the bypass document level validation flag.

Note: This only applies when an $out stage is specified

.

Parameters:

bypassDocumentValidation - If true, allows the write to opt-out of document level validation.

Returns:

this

Since:

1.2

MongoDB documentation

Aggregation

Since server release

3.2

toCollection

rx.Observable<Success> toCollection()

Aggregates documents according to the specified aggregation pipeline, which must end with a $out stage.

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Aggregation

collation

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

Sets the collation options

A null value represents the server default.

Parameters:

collation - the collation options to use

Returns:

this

Since:

1.3

Since server release

3.4