com.datastax.oss.dsbulk.executor.api.result

Interface WriteResult

All Superinterfaces:

Result

All Known Implementing Classes:

DefaultWriteResult, EmptyWriteResult

public interface WriteResult
extends Result

Represents the unique result of a write operation.

Method Summary

Modifier and Type	Method and Description
Stream<? extends Row>	getFailedWrites() If the query that produced this result was a conditional update, but the conditional update wasn't successful, returns a Stream containing the failed writes.
boolean	wasApplied() If the query that produced this result was a conditional update, returns whether the conditional update could be successfully applied.

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.result.Result

getBatchSize, getError, getExecutionInfo, getStatement, ifError, isSuccess

Method Detail

wasApplied

boolean wasApplied()

If the query that produced this result was a conditional update, returns whether the conditional update could be successfully applied.

If the query was unsuccessful (i.e., Result.getError() is not empty), then this method always returns false; if the query was successful but wasn't a conditional update, then this method always returns true.

Returns:

true if the conditional update was successfully applied, or if the write wasn't a conditional update; false otherwise.

getFailedWrites

Stream<? extends Row> getFailedWrites()

If the query that produced this result was a conditional update, but the conditional update wasn't successful, returns a Stream containing the failed writes.

If the query wasn't a conditional update, or if the conditional update was successful, this method returns an empty stream.

Note that the returned stream will contain one single item for single inserts and updates; only batch inserts and updates can generate a stream of more than one item.

The stream can only be consumed once.

Returns:

a Stream containing the failed writes, or an empty stream if no writes failed.