Package com.mongodb.operation

Class ParallelCollectionScanOperation<T>

java.lang.Object

com.mongodb.operation.ParallelCollectionScanOperation<T>

Type Parameters:

T - the operations result type.

All Implemented Interfaces:

AsyncReadOperation<java.util.List<AsyncBatchCursor<T>>>, ReadOperation<java.util.List<BatchCursor<T>>>

public class ParallelCollectionScanOperation<T>
extends java.lang.Object
implements AsyncReadOperation<java.util.List<AsyncBatchCursor<T>>>, ReadOperation<java.util.List<BatchCursor<T>>>

Return a list of cursors over the collection that can be used to scan it in parallel.

Note: As of MongoDB 2.6, this operation will work against a mongod, but not a mongos.

Since:

3.0

MongoDB documentation

parallelCollectionScan

Since server release

2.6

Constructor Summary

Constructors

Constructor and Description
ParallelCollectionScanOperation(MongoNamespace namespace, int numCursors, Decoder<T> decoder) Construct a new instance.

Method Summary

Modifier and Type	Method and Description
ParallelCollectionScanOperation<T>	batchSize(int batchSize) The batch size to use for each cursor.
java.util.List<BatchCursor<T>>	execute(ReadBinding binding) General execute which can return anything of type T
void	executeAsync(AsyncReadBinding binding, SingleResultCallback<java.util.List<AsyncBatchCursor<T>>> callback) General execute which can return anything of type T
int	getBatchSize() Gets the batch size to use for each cursor.
int	getNumCursors() Gets the number of cursors requested.
ReadConcern	getReadConcern() Gets the read concern
ParallelCollectionScanOperation<T>	readConcern(ReadConcern readConcern) Sets the read concern

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelCollectionScanOperation

public ParallelCollectionScanOperation(MongoNamespace namespace,
                                       int numCursors,
                                       Decoder<T> decoder)

Construct a new instance.

Parameters:

namespace - the database and collection namespace for the operation.

numCursors - The maximum number of cursors to return. Must be between 1 and 10000, inclusive.

decoder - the decoder for the result documents.

Method Detail

getNumCursors

public int getNumCursors()

Gets the number of cursors requested.

Returns:

number of cursors requested.

getBatchSize

public int getBatchSize()

Gets the batch size to use for each cursor. The default value is 0, which tells the server to use its own default batch size.

Returns:

batch size

MongoDB documentation

BatchSize

batchSize

public ParallelCollectionScanOperation<T> batchSize(int batchSize)

The batch size to use for each cursor.

Parameters:

batchSize - the batch size, which must be greater than or equal to 0

Returns:

this

MongoDB documentation

BatchSize

getReadConcern

public ReadConcern getReadConcern()

Gets the read concern

Returns:

the read concern

Since:

3.2

MongoDB documentation

Read Concern

readConcern

public ParallelCollectionScanOperation<T> readConcern(ReadConcern readConcern)

Sets the read concern

Parameters:

readConcern - the read concern

Returns:

this

Since:

3.2

MongoDB documentation

Read Concern

execute

public java.util.List<BatchCursor<T>> execute(ReadBinding binding)

Description copied from interface: ReadOperation

General execute which can return anything of type T

Specified by:

execute in interface ReadOperation<java.util.List<BatchCursor<T>>>

Parameters:

binding - the binding to execute in the context of

Returns:

T, the result of the execution

executeAsync

public void executeAsync(AsyncReadBinding binding,
                         SingleResultCallback<java.util.List<AsyncBatchCursor<T>>> callback)

Description copied from interface: AsyncReadOperation

General execute which can return anything of type T

Specified by:

executeAsync in interface AsyncReadOperation<java.util.List<AsyncBatchCursor<T>>>

Parameters:

binding - the binding to execute in the context of

callback - the callback to be called when the operation has been executed