com.mongodb

Class BulkWriteBatchCombiner

java.lang.Object

com.mongodb.BulkWriteBatchCombiner

class BulkWriteBatchCombiner
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private int	insertedCount
private int	matchedCount
private java.lang.Integer	modifiedCount
private boolean	ordered
private int	removedCount
private ServerAddress	serverAddress
private WriteConcern	writeConcern
private java.util.List<WriteConcernError>	writeConcernErrors
private java.util.Set<BulkWriteError>	writeErrors
private java.util.Set<BulkWriteUpsert>	writeUpserts

Constructor Summary

Constructors

Constructor and Description
BulkWriteBatchCombiner(ServerAddress serverAddress, WriteConcern writeConcern)

Method Summary

Modifier and Type	Method and Description
void	addErrorResult(BulkWriteException exception, IndexMap indexMap)
void	addErrorResult(java.util.List<BulkWriteError> writeErrors, WriteConcernError writeConcernError, IndexMap indexMap)
void	addResult(BulkWriteResult result, IndexMap indexMap)
void	addWriteConcernErrorResult(WriteConcernError writeConcernError)
void	addWriteErrorResult(BulkWriteError writeError, IndexMap indexMap)
private BulkWriteResult	createResult()
BulkWriteResult	getResult()
private boolean	hasWriteErrors()
private void	mergeUpserts(java.util.List<BulkWriteUpsert> upserts, IndexMap indexMap)
private void	mergeWriteConcernError(WriteConcernError writeConcernError)
private void	mergeWriteErrors(java.util.List<BulkWriteError> newWriteErrors, IndexMap indexMap)
boolean	shouldStopSendingMoreBatches()
private void	throwOnError()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

serverAddress

private final ServerAddress serverAddress

ordered

private final boolean ordered

writeConcern

private final WriteConcern writeConcern

insertedCount

private int insertedCount

matchedCount

private int matchedCount

removedCount

private int removedCount

modifiedCount

private java.lang.Integer modifiedCount

writeUpserts

private final java.util.Set<BulkWriteUpsert> writeUpserts

writeErrors

private final java.util.Set<BulkWriteError> writeErrors

writeConcernErrors

private final java.util.List<WriteConcernError> writeConcernErrors

Constructor Detail

BulkWriteBatchCombiner

public BulkWriteBatchCombiner(ServerAddress serverAddress,
                              WriteConcern writeConcern)

Method Detail

addResult

public void addResult(BulkWriteResult result,
                      IndexMap indexMap)

addErrorResult

public void addErrorResult(BulkWriteException exception,
                           IndexMap indexMap)

addWriteErrorResult

public void addWriteErrorResult(BulkWriteError writeError,
                                IndexMap indexMap)

addWriteConcernErrorResult

public void addWriteConcernErrorResult(WriteConcernError writeConcernError)

addErrorResult

public void addErrorResult(java.util.List<BulkWriteError> writeErrors,
                           WriteConcernError writeConcernError,
                           IndexMap indexMap)

mergeWriteConcernError

private void mergeWriteConcernError(WriteConcernError writeConcernError)

mergeWriteErrors

private void mergeWriteErrors(java.util.List<BulkWriteError> newWriteErrors,
                              IndexMap indexMap)

mergeUpserts

private void mergeUpserts(java.util.List<BulkWriteUpsert> upserts,
                          IndexMap indexMap)

getResult

public BulkWriteResult getResult()

shouldStopSendingMoreBatches

public boolean shouldStopSendingMoreBatches()

throwOnError

private void throwOnError()

createResult

private BulkWriteResult createResult()

hasWriteErrors

private boolean hasWriteErrors()