com.mongodb.async.client

Class DistinctIterableImpl<TDocument,TResult>

java.lang.Object

com.mongodb.async.client.MongoIterableImpl<TResult>

com.mongodb.async.client.DistinctIterableImpl<TDocument,TResult>

All Implemented Interfaces:

DistinctIterable<TResult>, MongoIterable<TResult>

class DistinctIterableImpl<TDocument,TResult>
extends MongoIterableImpl<TResult>
implements DistinctIterable<TResult>

Field Summary

Fields

Modifier and Type	Field and Description
private CodecRegistry	codecRegistry
private Collation	collation
private java.lang.Class<TDocument>	documentClass
private java.lang.String	fieldName
private Bson	filter
private long	maxTimeMS
private MongoNamespace	namespace
private java.lang.Class<TResult>	resultClass

Constructor Summary

Constructors

Constructor and Description
DistinctIterableImpl(ClientSession clientSession, MongoNamespace namespace, java.lang.Class<TDocument> documentClass, java.lang.Class<TResult> resultClass, CodecRegistry codecRegistry, ReadPreference readPreference, ReadConcern readConcern, AsyncOperationExecutor executor, java.lang.String fieldName, Bson filter)

Method Summary

Modifier and Type	Method and Description
(package private) AsyncReadOperation<AsyncBatchCursor<TResult>>	asAsyncReadOperation()
DistinctIterable<TResult>	batchSize(int batchSize) Sets the number of documents to return per batch.
DistinctIterable<TResult>	collation(Collation collation) Sets the collation options
DistinctIterable<TResult>	filter(Bson filter) Sets the query filter to apply to the query.
DistinctIterable<TResult>	maxTime(long maxTime, java.util.concurrent.TimeUnit timeUnit) Sets the maximum execution time on the server for this operation.

Methods inherited from class com.mongodb.async.client.MongoIterableImpl

batchCursor, first, forEach, getBatchSize, getClientSession, getExecutor, getReadConcern, getReadPreference, into, map, toBsonDocumentOrNull, toBsonDocumentOrNull

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mongodb.async.client.MongoIterable

batchCursor, first, forEach, into, map

Field Detail

namespace

private final MongoNamespace namespace

documentClass

private final java.lang.Class<TDocument> documentClass

resultClass

private final java.lang.Class<TResult> resultClass

codecRegistry

private final CodecRegistry codecRegistry

fieldName

private final java.lang.String fieldName

filter

private Bson filter

maxTimeMS

private long maxTimeMS

collation

private Collation collation

Constructor Detail

DistinctIterableImpl

DistinctIterableImpl(ClientSession clientSession,
                     MongoNamespace namespace,
                     java.lang.Class<TDocument> documentClass,
                     java.lang.Class<TResult> resultClass,
                     CodecRegistry codecRegistry,
                     ReadPreference readPreference,
                     ReadConcern readConcern,
                     AsyncOperationExecutor executor,
                     java.lang.String fieldName,
                     Bson filter)

Method Detail

filter

public DistinctIterable<TResult> filter(Bson filter)

Description copied from interface: DistinctIterable

Sets the query filter to apply to the query.

Specified by:

filter in interface DistinctIterable<TResult>

Parameters:

filter - the filter, which may be null.

Returns:

this

maxTime

public DistinctIterable<TResult> maxTime(long maxTime,
                                         java.util.concurrent.TimeUnit timeUnit)

Description copied from interface: DistinctIterable

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

Specified by:

maxTime in interface DistinctIterable<TResult>

Parameters:

maxTime - the max time

timeUnit - the time unit, which may not be null

Returns:

this

batchSize

public DistinctIterable<TResult> batchSize(int batchSize)

Description copied from interface: MongoIterable

Sets the number of documents to return per batch.

Specified by:

batchSize in interface DistinctIterable<TResult>

Specified by:

batchSize in interface MongoIterable<TResult>

Overrides:

batchSize in class MongoIterableImpl<TResult>

Parameters:

batchSize - the batch size

Returns:

this

collation

public DistinctIterable<TResult> collation(Collation collation)

Description copied from interface: DistinctIterable

Sets the collation options

A null value represents the server default.

Specified by:

collation in interface DistinctIterable<TResult>

Parameters:

collation - the collation options to use

Returns:

this

asAsyncReadOperation

AsyncReadOperation<AsyncBatchCursor<TResult>> asAsyncReadOperation()

Specified by:

asAsyncReadOperation in class MongoIterableImpl<TResult>