private class DBCollectionImpl.Run
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
private class |
DBCollectionImpl.Run.RunExecutor |
| Modifier and Type | Field and Description |
|---|---|
private java.lang.Boolean |
bypassDocumentValidation |
private DBEncoder |
encoder |
private IndexMap |
indexMap |
private WriteRequest.Type |
type |
private WriteConcern |
writeConcern |
private java.util.List<WriteRequest> |
writeRequests |
| Constructor and Description |
|---|
Run(WriteRequest.Type type,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern,
DBEncoder encoder) |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
add(WriteRequest writeRequest,
int originalIndex) |
(package private) BulkWriteResult |
execute(DBPort port) |
(package private) BulkWriteResult |
executeInserts(java.util.List<InsertRequest> insertRequests,
DBPort port) |
(package private) BulkWriteResult |
executeRemoves(java.util.List<RemoveRequest> removeRequests,
DBPort port) |
(package private) BulkWriteResult |
executeReplaces(java.util.List<ModifyRequest> replaceRequests,
DBPort port) |
(package private) BulkWriteResult |
executeUpdates(java.util.List<ModifyRequest> updateRequests,
DBPort port) |
private java.util.List<InsertRequest> |
getWriteRequestsAsInsertRequests() |
private java.util.List<ModifyRequest> |
getWriteRequestsAsModifyRequests() |
private java.util.List |
getWriteRequestsAsRaw() |
private java.util.List<RemoveRequest> |
getWriteRequestsAsRemoveRequests() |
int |
size() |
private final java.util.List<WriteRequest> writeRequests
private final WriteRequest.Type type
private final java.lang.Boolean bypassDocumentValidation
private final WriteConcern writeConcern
private final DBEncoder encoder
private IndexMap indexMap
Run(WriteRequest.Type type, java.lang.Boolean bypassDocumentValidation, WriteConcern writeConcern, DBEncoder encoder)
void add(WriteRequest writeRequest, int originalIndex)
public int size()
BulkWriteResult execute(DBPort port)
private java.util.List getWriteRequestsAsRaw()
private java.util.List<RemoveRequest> getWriteRequestsAsRemoveRequests()
private java.util.List<InsertRequest> getWriteRequestsAsInsertRequests()
private java.util.List<ModifyRequest> getWriteRequestsAsModifyRequests()
BulkWriteResult executeUpdates(java.util.List<ModifyRequest> updateRequests, DBPort port)
BulkWriteResult executeReplaces(java.util.List<ModifyRequest> replaceRequests, DBPort port)
BulkWriteResult executeRemoves(java.util.List<RemoveRequest> removeRequests, DBPort port)
BulkWriteResult executeInserts(java.util.List<InsertRequest> insertRequests, DBPort port)