com.datastax.oss.dsbulk.workflow.api.error

Class AbsoluteErrorThreshold

java.lang.Object

com.datastax.oss.dsbulk.workflow.api.error.AbsoluteErrorThreshold

All Implemented Interfaces:

ErrorThreshold

public class AbsoluteErrorThreshold
extends Object
implements ErrorThreshold

Method Summary

Modifier and Type	Method and Description
boolean	checkThresholdExceeded(long errorCount, Number totalItems) Checks whether the error threshold was exceeded.
long	getMaxErrors()
String	thresholdAsString() Returns a textual description of this threshold, mainly for informational purposes, e.g.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.datastax.oss.dsbulk.workflow.api.error.ErrorThreshold

forAbsoluteValue, forRatio, unlimited

Method Detail

checkThresholdExceeded

public boolean checkThresholdExceeded(long errorCount,
                                      @NonNull
                                      Number totalItems)

Description copied from interface: ErrorThreshold

Checks whether the error threshold was exceeded.

Specified by:

checkThresholdExceeded in interface ErrorThreshold

Parameters:

errorCount - the current number of errors encountered.

totalItems - the total number of items processed so far.

Returns:

true if the threshold was exceeded, or false otherwise.

thresholdAsString

public String thresholdAsString()

Description copied from interface: ErrorThreshold

Returns a textual description of this threshold, mainly for informational purposes, e.g. when creating error messages.

Specified by:

thresholdAsString in interface ErrorThreshold

Returns:

textual description of this threshold.

getMaxErrors

public long getMaxErrors()