AggregateOperation (The Adobe AEM Quickstart and Web Application.)

java.lang.Object
- com.mongodb.operation.AggregateOperation<T>

Type Parameters:

T - the operations result type.

All Implemented Interfaces:

AsyncReadOperation<AsyncBatchCursor<T>>, ReadOperation<BatchCursor<T>>
```
public class AggregateOperation<T>
extends java.lang.Object
implements AsyncReadOperation<AsyncBatchCursor<T>>, ReadOperation<BatchCursor<T>>
```
An operation that executes an aggregation query.

Since:

3.0

Constructor Summary

Constructors
Constructor and Description
`AggregateOperation(MongoNamespace namespace, java.util.List<BsonDocument> pipeline, Decoder<T> decoder)` Construct a new instance.

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`AggregateOperation<T>`	`allowDiskUse(java.lang.Boolean allowDiskUse)` Enables writing to temporary files.
`ReadOperation<BsonDocument>`	`asExplainableOperation(ExplainVerbosity explainVerbosity)` Gets an operation whose execution explains this operation.
`AsyncReadOperation<BsonDocument>`	`asExplainableOperationAsync(ExplainVerbosity explainVerbosity)` Gets an operation whose execution explains this operation.
`AggregateOperation<T>`	`batchSize(java.lang.Integer batchSize)` Sets the number of documents to return per batch.
`AggregateOperation<T>`	`collation(Collation collation)` Sets the collation options
`AggregateOperation<T>`	`comment(java.lang.String comment)` Sets the comment to the aggregation.
`BatchCursor<T>`	`execute(ReadBinding binding)` General execute which can return anything of type T
`void`	`executeAsync(AsyncReadBinding binding, SingleResultCallback<AsyncBatchCursor<T>> callback)` General execute which can return anything of type T
`java.lang.Boolean`	`getAllowDiskUse()` Whether writing to temporary files is enabled.
`java.lang.Integer`	`getBatchSize()` Gets the number of documents to return per batch.
`Collation`	`getCollation()` Returns the collation options
`java.lang.String`	`getComment()` Returns the comment to send with the aggregate.
`BsonDocument`	`getHint()` Returns the hint for which index to use.
`BsonValue`	`getHintBsonValue()` Returns the hint BsonValue for which index to use.
`long`	`getMaxAwaitTime(java.util.concurrent.TimeUnit timeUnit)` The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor query.
`long`	`getMaxTime(java.util.concurrent.TimeUnit timeUnit)` Gets the maximum execution time on the server for this operation.
`java.util.List<BsonDocument>`	`getPipeline()` Gets the aggregation pipeline.
`java.lang.Boolean`	`getUseCursor()` 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.
`AggregateOperation<T>`	`hint(BsonValue hint)` Sets the hint for which index to use.
`AggregateOperation<T>`	`maxAwaitTime(long maxAwaitTime, java.util.concurrent.TimeUnit timeUnit)` Sets the maximum await execution time on the server for this operation.
`AggregateOperation<T>`	`maxTime(long maxTime, java.util.concurrent.TimeUnit timeUnit)` Sets the maximum execution time on the server for this operation.
`java.lang.String`	`toString()`
`AggregateOperation<T>`	`useCursor(java.lang.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.

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - AggregateOperation
```
public AggregateOperation(MongoNamespace namespace,
                          java.util.List<BsonDocument> pipeline,
                          Decoder<T> decoder)
```
    Construct a new instance.
    
    Parameters:
    
    namespace - the database and collection namespace for the operation.
    
    pipeline - the aggregation pipeline.
    
    decoder - the decoder for the result documents.
- Method Detail
  - getPipeline
```
public java.util.List<BsonDocument> getPipeline()
```
    Gets the aggregation pipeline.
    
    Returns:
    
    the pipeline
  - getAllowDiskUse
```
public java.lang.Boolean getAllowDiskUse()
```
    Whether writing to temporary files is enabled. A null value indicates that it's unspecified.
    
    Returns:
    
    true if writing to temporary files is enabled
  - allowDiskUse
```
public AggregateOperation<T> allowDiskUse(java.lang.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
  - getBatchSize
```
public java.lang.Integer getBatchSize()
```
    Gets the number of documents to return per batch. Default to 0, which indicates that the server chooses an appropriate batch size.
    
    Returns:
    
    the batch size, which may be null
  - batchSize
```
public AggregateOperation<T> batchSize(java.lang.Integer batchSize)
```
    Sets the number of documents to return per batch.
    
    Parameters:
    
    batchSize - the batch size
    
    Returns:
    
    this
  - getMaxAwaitTime
```
public long getMaxAwaitTime(java.util.concurrent.TimeUnit timeUnit)
```
    The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor query. This only applies to a TAILABLE_AWAIT cursor. When the cursor is not a TAILABLE_AWAIT cursor, this option is ignored. A zero value will be ignored.
    
    Parameters:
    
    timeUnit - the time unit to return the result in
    
    Returns:
    
    the maximum await execution time in the given time unit
  - maxAwaitTime
```
public AggregateOperation<T> maxAwaitTime(long maxAwaitTime,
                                          java.util.concurrent.TimeUnit timeUnit)
```
    Sets the maximum await execution time on the server for this operation.
    
    Parameters:
    
    maxAwaitTime - the max await time. A value less than one will be ignored, and indicates that the driver should respect the server's default value
    
    timeUnit - the time unit, which may not be null
    
    Returns:
    
    this
  - getMaxTime
```
public long getMaxTime(java.util.concurrent.TimeUnit timeUnit)
```
    Gets the maximum execution time on the server for this operation. The default is 0, which places no limit on the execution time.
    
    Parameters:
    
    timeUnit - the time unit to return the result in
    
    Returns:
    
    the maximum execution time in the given time unit
  - maxTime
```
public AggregateOperation<T> maxTime(long maxTime,
                                     java.util.concurrent.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
  - getUseCursor
```
@Deprecated
public java.lang.Boolean getUseCursor()
```
    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.
    
    Gets whether the server should use a cursor to return results. The default value is null, in which case a cursor will be used if the server supports it.
    
    Returns:
    
    whether the server should use a cursor to return results
  - useCursor
```
@Deprecated
public AggregateOperation<T> useCursor(java.lang.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.
    
    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
  - getCollation
```
public Collation getCollation()
```
    Returns the collation options
    
    Returns:
    
    the collation options
    
    Since:
    
    3.4
  - collation
```
public AggregateOperation<T> collation(Collation collation)
```
    Sets the collation options
    A null value represents the server default.
    
    Parameters:
    
    collation - the collation options to use
    
    Returns:
    
    this
    
    Since:
    
    3.4
  - getComment
```
public java.lang.String getComment()
```
    Returns the comment to send with the aggregate. The default is not to include a comment with the aggregation.
    
    Returns:
    
    the comment
    
    Since:
    
    3.6
  - comment
```
public AggregateOperation<T> comment(java.lang.String comment)
```
    Sets the comment to the aggregation. A null value means no comment is set.
    
    Parameters:
    
    comment - the comment
    
    Returns:
    
    this
    
    Since:
    
    3.6
  - getHint
```
public BsonDocument getHint()
```
    Returns the hint for which index to use. The default is not to set a hint.
    
    Returns:
    
    the hint
    
    Since:
    
    3.6
  - getHintBsonValue
```
public BsonValue getHintBsonValue()
```
    Returns the hint BsonValue for which index to use. The default is not to set a hint.
    Hints can either be a BsonString or a BsonDocument.
    
    Returns:
    
    the hint
    
    Since:
    
    3.8
  - hint
```
public AggregateOperation<T> hint(BsonValue hint)
```
    Sets the hint for which index to use. A null value means no hint is set.
    
    Parameters:
    
    hint - the hint
    
    Returns:
    
    this
    
    Since:
    
    3.6
  - execute
```
public 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<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<AsyncBatchCursor<T>> callback)
```
    Description copied from interface: AsyncReadOperation
    
    General execute which can return anything of type T
    
    Specified by:
    
    executeAsync in interface AsyncReadOperation<AsyncBatchCursor<T>>
    
    Parameters:
    
    binding - the binding to execute in the context of
    
    callback - the callback to be called when the operation has been executed
  - asExplainableOperation
```
public ReadOperation<BsonDocument> asExplainableOperation(ExplainVerbosity explainVerbosity)
```
    Gets an operation whose execution explains this operation.
    
    Parameters:
    
    explainVerbosity - the explain verbosity
    
    Returns:
    
    a read operation that when executed will explain this operation
  - asExplainableOperationAsync
```
public AsyncReadOperation<BsonDocument> asExplainableOperationAsync(ExplainVerbosity explainVerbosity)
```
    Gets an operation whose execution explains this operation.
    
    Parameters:
    
    explainVerbosity - the explain verbosity
    
    Returns:
    
    a read operation that when executed will explain this operation
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object

Class AggregateOperation<T>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

AggregateOperation

Method Detail

getPipeline

getAllowDiskUse

allowDiskUse

getBatchSize

batchSize

getMaxAwaitTime

maxAwaitTime

getMaxTime

maxTime

getUseCursor

useCursor

getCollation

collation

getComment

comment

getHint

getHintBsonValue

hint

execute

executeAsync

asExplainableOperation

asExplainableOperationAsync

toString