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

Class DefaultWriteResult

java.lang.Object

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

All Implemented Interfaces:

Result, WriteResult

public final class DefaultWriteResult
extends Object
implements WriteResult

Constructor Summary

Constructors

Constructor and Description
DefaultWriteResult(BulkExecutionException error)
DefaultWriteResult(Statement<?> statement, AsyncResultSet rs)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Optional<BulkExecutionException>	getError() Returns an optional BulkExecutionException.
Optional<ExecutionInfo>	getExecutionInfo()
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.
Statement<?>	getStatement() Returns the Statement that has been executed to obtain this result.
int	hashCode()
boolean	isSuccess() Returns true if the statement execution succeeded, false otherwise.
String	toString()
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 class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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

getBatchSize, getError, getExecutionInfo, getStatement, ifError, isSuccess

Constructor Detail

DefaultWriteResult

public DefaultWriteResult(@NonNull
                          Statement<?> statement,
                          @NonNull
                          AsyncResultSet rs)

DefaultWriteResult

public DefaultWriteResult(@NonNull
                          BulkExecutionException error)

Method Detail

wasApplied

public boolean wasApplied()

Description copied from interface: WriteResult

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.

Specified by:

wasApplied in interface WriteResult

Returns:

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

getFailedWrites

public Stream<? extends Row> getFailedWrites()

Description copied from interface: WriteResult

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.

Specified by:

getFailedWrites in interface WriteResult

Returns:

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

toString

public String toString()

Overrides:

toString in class Object

isSuccess

public boolean isSuccess()

Description copied from interface: Result

Returns true if the statement execution succeeded, false otherwise.

In case of conditional updates, this method returns true as long as the statement was executed, even if the conditional update itself could not be applied.

Specified by:

isSuccess in interface Result

Returns:

true if the statement execution succeeded, false otherwise.

getStatement

@NonNull
public Statement<?> getStatement()

Description copied from interface: Result

Returns the Statement that has been executed to obtain this result.

Specified by:

getStatement in interface Result

Returns:

the statement that has been executed.

getError

@NonNull
public Optional<BulkExecutionException> getError()

Description copied from interface: Result

Returns an optional BulkExecutionException. The value is only present if the statement execution failed, in which case, this exception contains the cause of the failure.

Specified by:

getError in interface Result

Returns:

an optional BulkExecutionException.

getExecutionInfo

@NonNull
public Optional<ExecutionInfo> getExecutionInfo()

Specified by:

getExecutionInfo in interface Result

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object