private class MixedBulkWriteOperation.Run
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
private class |
MixedBulkWriteOperation.Run.AsyncRunExecutor |
private class |
MixedBulkWriteOperation.Run.BaseRunExecutor |
private class |
MixedBulkWriteOperation.Run.RunExecutor |
Modifier and Type | Field and Description |
---|---|
private java.lang.Boolean |
bypassDocumentValidation |
private IndexMap |
indexMap |
private boolean |
ordered |
private java.util.List |
runWrites |
private WriteRequest.Type |
type |
Constructor and Description |
---|
Run(WriteRequest.Type type,
boolean ordered,
java.lang.Boolean bypassDocumentValidation) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
add(WriteRequest writeRequest,
int originalIndex) |
(package private) BulkWriteResult |
execute(Connection connection) |
(package private) void |
executeAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
(package private) MixedBulkWriteOperation.Run.AsyncRunExecutor |
getDeletesRunExecutor(java.util.List<DeleteRequest> deleteRequests,
AsyncConnection connection) |
(package private) MixedBulkWriteOperation.Run.RunExecutor |
getDeletesRunExecutor(java.util.List<DeleteRequest> deleteRequests,
Connection connection) |
(package private) MixedBulkWriteOperation.Run.AsyncRunExecutor |
getInsertsRunExecutor(java.util.List<InsertRequest> insertRequests,
java.lang.Boolean bypassDocumentValidation,
AsyncConnection connection) |
(package private) MixedBulkWriteOperation.Run.RunExecutor |
getInsertsRunExecutor(java.util.List<InsertRequest> insertRequests,
java.lang.Boolean bypassDocumentValidation,
Connection connection) |
(package private) MixedBulkWriteOperation.Run.AsyncRunExecutor |
getUpdatesRunExecutor(java.util.List<UpdateRequest> updates,
java.lang.Boolean bypassDocumentValidation,
AsyncConnection connection) |
(package private) MixedBulkWriteOperation.Run.RunExecutor |
getUpdatesRunExecutor(java.util.List<UpdateRequest> updates,
java.lang.Boolean bypassDocumentValidation,
Connection connection) |
int |
size() |
private final java.util.List runWrites
private final WriteRequest.Type type
private final boolean ordered
private final java.lang.Boolean bypassDocumentValidation
private IndexMap indexMap
Run(WriteRequest.Type type, boolean ordered, java.lang.Boolean bypassDocumentValidation)
void add(WriteRequest writeRequest, int originalIndex)
public int size()
BulkWriteResult execute(Connection connection)
void executeAsync(AsyncConnection connection, SingleResultCallback<BulkWriteResult> callback)
MixedBulkWriteOperation.Run.RunExecutor getDeletesRunExecutor(java.util.List<DeleteRequest> deleteRequests, Connection connection)
MixedBulkWriteOperation.Run.RunExecutor getInsertsRunExecutor(java.util.List<InsertRequest> insertRequests, java.lang.Boolean bypassDocumentValidation, Connection connection)
MixedBulkWriteOperation.Run.RunExecutor getUpdatesRunExecutor(java.util.List<UpdateRequest> updates, java.lang.Boolean bypassDocumentValidation, Connection connection)
MixedBulkWriteOperation.Run.AsyncRunExecutor getDeletesRunExecutor(java.util.List<DeleteRequest> deleteRequests, AsyncConnection connection)
MixedBulkWriteOperation.Run.AsyncRunExecutor getInsertsRunExecutor(java.util.List<InsertRequest> insertRequests, java.lang.Boolean bypassDocumentValidation, AsyncConnection connection)
MixedBulkWriteOperation.Run.AsyncRunExecutor getUpdatesRunExecutor(java.util.List<UpdateRequest> updates, java.lang.Boolean bypassDocumentValidation, AsyncConnection connection)