final class BulkWriteBatch
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
(package private) static class |
BulkWriteBatch.WriteRequestEncoder |
(package private) static class |
BulkWriteBatch.WriteRequestWithIndex |
Modifier and Type | Field and Description |
---|---|
private WriteRequest.Type |
batchType |
private BulkWriteBatchCombiner |
bulkWriteBatchCombiner |
private java.lang.Boolean |
bypassDocumentValidation |
private BsonDocument |
command |
private ConnectionDescription |
connectionDescription |
private static Decoder<BsonDocument> |
DECODER |
private IndexMap |
indexMap |
private MongoNamespace |
namespace |
private static FieldNameValidator |
NO_OP_FIELD_NAME_VALIDATOR |
private boolean |
ordered |
private SplittablePayload |
payload |
private static CodecRegistry |
REGISTRY |
private boolean |
retryWrites |
private SessionContext |
sessionContext |
private java.util.List<BulkWriteBatch.WriteRequestWithIndex> |
unprocessed |
private static BulkWriteBatch.WriteRequestEncoder |
WRITE_REQUEST_ENCODER |
private WriteConcern |
writeConcern |
Modifier | Constructor and Description |
---|---|
private |
BulkWriteBatch(MongoNamespace namespace,
ConnectionDescription connectionDescription,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
boolean retryWrites,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
IndexMap indexMap,
WriteRequest.Type batchType,
BsonDocument command,
SplittablePayload payload,
java.util.List<BulkWriteBatch.WriteRequestWithIndex> unprocessed,
SessionContext sessionContext) |
private |
BulkWriteBatch(MongoNamespace namespace,
ConnectionDescription connectionDescription,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
boolean retryWrites,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
java.util.List<BulkWriteBatch.WriteRequestWithIndex> writeRequestsWithIndices,
SessionContext sessionContext) |
private static final CodecRegistry REGISTRY
private static final Decoder<BsonDocument> DECODER
private static final FieldNameValidator NO_OP_FIELD_NAME_VALIDATOR
private static final BulkWriteBatch.WriteRequestEncoder WRITE_REQUEST_ENCODER
private final MongoNamespace namespace
private final ConnectionDescription connectionDescription
private final boolean ordered
private final WriteConcern writeConcern
private final java.lang.Boolean bypassDocumentValidation
private final boolean retryWrites
private final BulkWriteBatchCombiner bulkWriteBatchCombiner
private final IndexMap indexMap
private final WriteRequest.Type batchType
private final BsonDocument command
private final SplittablePayload payload
private final java.util.List<BulkWriteBatch.WriteRequestWithIndex> unprocessed
private final SessionContext sessionContext
private BulkWriteBatch(MongoNamespace namespace, ConnectionDescription connectionDescription, boolean ordered, WriteConcern writeConcern, java.lang.Boolean bypassDocumentValidation, boolean retryWrites, BulkWriteBatchCombiner bulkWriteBatchCombiner, java.util.List<BulkWriteBatch.WriteRequestWithIndex> writeRequestsWithIndices, SessionContext sessionContext)
private BulkWriteBatch(MongoNamespace namespace, ConnectionDescription connectionDescription, boolean ordered, WriteConcern writeConcern, java.lang.Boolean bypassDocumentValidation, boolean retryWrites, BulkWriteBatchCombiner bulkWriteBatchCombiner, IndexMap indexMap, WriteRequest.Type batchType, BsonDocument command, SplittablePayload payload, java.util.List<BulkWriteBatch.WriteRequestWithIndex> unprocessed, SessionContext sessionContext)
public static BulkWriteBatch createBulkWriteBatch(MongoNamespace namespace, ServerDescription serverDescription, ConnectionDescription connectionDescription, boolean ordered, WriteConcern writeConcern, java.lang.Boolean bypassDocumentValidation, boolean retryWrites, java.util.List<? extends WriteRequest> writeRequests, SessionContext sessionContext)
public void addResult(BsonDocument result)
public boolean getRetryWrites()
public BsonDocument getCommand()
public SplittablePayload getPayload()
public Decoder<BsonDocument> getDecoder()
public BulkWriteResult getResult()
public boolean hasErrors()
public MongoBulkWriteException getError()
public boolean shouldProcessBatch()
public boolean hasAnotherBatch()
public BulkWriteBatch getNextBatch()
public FieldNameValidator getFieldNameValidator()
private BulkWriteResult getBulkWriteResult(BsonDocument result)
private java.util.List<BulkWriteUpsert> getUpsertedItems(BsonDocument result)
private java.lang.Integer getModifiedCount(BsonDocument result)
private boolean hasError(BsonDocument result)
private MongoBulkWriteException getBulkWriteException(BsonDocument result)
private java.util.List<BulkWriteError> getWriteErrors(BsonDocument result)
private WriteConcernError getWriteConcernError(BsonDocument result)
private java.lang.String getCommandName(WriteRequest.Type batchType)
private SplittablePayload.Type getPayloadType(WriteRequest.Type batchType)
private static Codec<BsonDocument> getCodec(BsonDocument document)
private static boolean isRetryable(WriteRequest writeRequest)