Package com.mongodb.connection

Class BulkWriteBatchCombiner

java.lang.Object

com.mongodb.connection.BulkWriteBatchCombiner

public class BulkWriteBatchCombiner
extends Object

This class is not part of the public API. It may be changed or removed at any time.

Constructor Summary

Constructors

Constructor	Description
BulkWriteBatchCombiner(ServerAddress serverAddress, boolean ordered, WriteConcern writeConcern)	Construct an instance.

Method Summary

Modifier and Type	Method	Description
void	addErrorResult(MongoBulkWriteException exception, com.mongodb.internal.connection.IndexMap indexMap)	Add an error result
void	addErrorResult(List<BulkWriteError> writeErrors, WriteConcernError writeConcernError, com.mongodb.internal.connection.IndexMap indexMap)	Add a list of error results and a write concern error
void	addResult(BulkWriteResult result, com.mongodb.internal.connection.IndexMap indexMap)	Add a result
void	addWriteConcernErrorResult(WriteConcernError writeConcernError)	Add a write concern error result
void	addWriteErrorResult(BulkWriteError writeError, com.mongodb.internal.connection.IndexMap indexMap)	Add a write error result
MongoBulkWriteException	getError()	Gets the combined errors as an exception
BulkWriteResult	getResult()	Gets the combined result.
boolean	hasErrors()	Gets whether there are errors in the combined result.
boolean	shouldStopSendingMoreBatches()	True if ordered and has write errors.

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkWriteBatchCombiner

public BulkWriteBatchCombiner(ServerAddress serverAddress,
                              boolean ordered,
                              WriteConcern writeConcern)

Construct an instance.

Parameters:

serverAddress - the server address

ordered - ordered

writeConcern - the write concern

Method Detail

addResult

public void addResult(BulkWriteResult result,
                      com.mongodb.internal.connection.IndexMap indexMap)

Add a result

Parameters:

result - the result

indexMap - the index map

addErrorResult

public void addErrorResult(MongoBulkWriteException exception,
                           com.mongodb.internal.connection.IndexMap indexMap)

Add an error result

Parameters:

exception - the exception

indexMap - the index map

addWriteErrorResult

public void addWriteErrorResult(BulkWriteError writeError,
                                com.mongodb.internal.connection.IndexMap indexMap)

Add a write error result

Parameters:

writeError - the write error

indexMap - the index map

addWriteConcernErrorResult

public void addWriteConcernErrorResult(WriteConcernError writeConcernError)

Add a write concern error result

Parameters:

writeConcernError - the write concern error

addErrorResult

public void addErrorResult(List<BulkWriteError> writeErrors,
                           WriteConcernError writeConcernError,
                           com.mongodb.internal.connection.IndexMap indexMap)

Add a list of error results and a write concern error

Parameters:

writeErrors - the errors

writeConcernError - the write concern error

indexMap - the index map

getResult

public BulkWriteResult getResult()

Gets the combined result.

Returns:

the result

shouldStopSendingMoreBatches

public boolean shouldStopSendingMoreBatches()

True if ordered and has write errors.

Returns:

true if no more batches should be sent

hasErrors

public boolean hasErrors()

Gets whether there are errors in the combined result.

Returns:

whether there are errors in the combined result

getError

public MongoBulkWriteException getError()

Gets the combined errors as an exception

Returns:

the bulk write exception, or null if there were no errors