public class AggregateToCollectionOperation extends java.lang.Object implements AsyncWriteOperation<java.lang.Void>, WriteOperation<java.lang.Void>
Constructor and Description |
---|
AggregateToCollectionOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline)
Deprecated.
|
AggregateToCollectionOperation(MongoNamespace namespace,
java.util.List<BsonDocument> pipeline,
WriteConcern writeConcern)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
AggregateToCollectionOperation |
allowDiskUse(java.lang.Boolean allowDiskUse)
Enables writing to temporary files.
|
ReadOperation<BsonDocument> |
asExplainableOperation(ExplainVerbosity explainVerbosity)
Gets an operation whose execution explains this operation.
|
AggregateToCollectionOperation |
bypassDocumentValidation(java.lang.Boolean bypassDocumentValidation)
Sets the bypass document level validation flag.
|
AggregateToCollectionOperation |
collation(Collation collation)
Sets the collation options
|
AggregateToCollectionOperation |
comment(java.lang.String comment)
Sets the comment to the aggregation.
|
java.lang.Void |
execute(WriteBinding binding)
General execute which can return anything of type T
|
void |
executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback)
General execute which can return anything of type T
|
java.lang.Boolean |
getAllowDiskUse()
Whether writing to temporary files is enabled.
|
java.lang.Boolean |
getBypassDocumentValidation()
Gets the bypass document level validation flag
|
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.
|
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.
|
WriteConcern |
getWriteConcern()
Gets the write concern.
|
AggregateToCollectionOperation |
hint(BsonDocument hint)
Sets the hint for which index to use.
|
AggregateToCollectionOperation |
maxTime(long maxTime,
java.util.concurrent.TimeUnit timeUnit)
Sets the maximum execution time on the server for this operation.
|
@Deprecated public AggregateToCollectionOperation(MongoNamespace namespace, java.util.List<BsonDocument> pipeline)
AggregateToCollectionOperation(MongoNamespace, List, WriteConcern)
namespace
- the database and collection namespace for the operation.pipeline
- the aggregation pipeline.public AggregateToCollectionOperation(MongoNamespace namespace, java.util.List<BsonDocument> pipeline, WriteConcern writeConcern)
namespace
- the database and collection namespace for the operation.pipeline
- the aggregation pipeline.writeConcern
- the write concern to applypublic java.util.List<BsonDocument> getPipeline()
public WriteConcern getWriteConcern()
public java.lang.Boolean getAllowDiskUse()
public AggregateToCollectionOperation allowDiskUse(java.lang.Boolean allowDiskUse)
allowDiskUse
- true if writing to temporary files is enabledpublic long getMaxTime(java.util.concurrent.TimeUnit timeUnit)
timeUnit
- the time unit to return the result inpublic AggregateToCollectionOperation maxTime(long maxTime, java.util.concurrent.TimeUnit timeUnit)
maxTime
- the max timetimeUnit
- the time unit, which may not be nullpublic java.lang.Boolean getBypassDocumentValidation()
public AggregateToCollectionOperation bypassDocumentValidation(java.lang.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.public Collation getCollation()
public AggregateToCollectionOperation collation(Collation collation)
A null value represents the server default.
collation
- the collation options to usepublic java.lang.String getComment()
public AggregateToCollectionOperation comment(java.lang.String comment)
comment
- the commentpublic BsonDocument getHint()
public AggregateToCollectionOperation hint(BsonDocument hint)
hint
- the hintpublic ReadOperation<BsonDocument> asExplainableOperation(ExplainVerbosity explainVerbosity)
explainVerbosity
- the explain verbositypublic java.lang.Void execute(WriteBinding binding)
WriteOperation
execute
in interface WriteOperation<java.lang.Void>
binding
- the binding to execute in the context ofpublic void executeAsync(AsyncWriteBinding binding, SingleResultCallback<java.lang.Void> callback)
AsyncWriteOperation
executeAsync
in interface AsyncWriteOperation<java.lang.Void>
binding
- the binding to execute in the context ofcallback
- the callback to be called when the operation has been executed