com.datastax.oss.dsbulk.workflow.commons.policies.retry

Class MultipleRetryPolicy

java.lang.Object

com.datastax.oss.dsbulk.workflow.commons.policies.retry.MultipleRetryPolicy

All Implemented Interfaces:

RetryPolicy, AutoCloseable

public class MultipleRetryPolicy
extends Object
implements RetryPolicy

Constructor Summary

Constructors

Constructor and Description
MultipleRetryPolicy(DriverContext context, String profileName)

Method Summary

Modifier and Type	Method and Description
void	close()
RetryDecision	onErrorResponse(Request request, CoordinatorException error, int retryCount) Deprecated.
RetryDecision	onReadTimeout(Request request, ConsistencyLevel cl, int blockFor, int received, boolean dataPresent, int retryCount) Deprecated.
RetryDecision	onRequestAborted(Request request, Throwable error, int retryCount) Deprecated.
RetryDecision	onUnavailable(Request request, ConsistencyLevel cl, int required, int alive, int retryCount) Deprecated.
RetryDecision	onWriteTimeout(Request request, ConsistencyLevel cl, WriteType writeType, int blockFor, int received, int retryCount) Deprecated.

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.driver.api.core.retry.RetryPolicy

onErrorResponseVerdict, onReadTimeoutVerdict, onRequestAbortedVerdict, onUnavailableVerdict, onWriteTimeoutVerdict

Constructor Detail

MultipleRetryPolicy

public MultipleRetryPolicy(DriverContext context,
                           String profileName)

Method Detail

onReadTimeout

@Deprecated
public RetryDecision onReadTimeout(@NonNull
                                               Request request,
                                               @NonNull
                                               ConsistencyLevel cl,
                                               int blockFor,
                                               int received,
                                               boolean dataPresent,
                                               int retryCount)

Deprecated.

Specified by:

onReadTimeout in interface RetryPolicy

onWriteTimeout

@Deprecated
public RetryDecision onWriteTimeout(@NonNull
                                                Request request,
                                                @NonNull
                                                ConsistencyLevel cl,
                                                @NonNull
                                                WriteType writeType,
                                                int blockFor,
                                                int received,
                                                int retryCount)

Deprecated.

Specified by:

onWriteTimeout in interface RetryPolicy

onUnavailable

@Deprecated
public RetryDecision onUnavailable(@NonNull
                                               Request request,
                                               @NonNull
                                               ConsistencyLevel cl,
                                               int required,
                                               int alive,
                                               int retryCount)

Deprecated.

Specified by:

onUnavailable in interface RetryPolicy

onRequestAborted

@Deprecated
public RetryDecision onRequestAborted(@NonNull
                                                  Request request,
                                                  @NonNull
                                                  Throwable error,
                                                  int retryCount)

Deprecated.

Specified by:

onRequestAborted in interface RetryPolicy

onErrorResponse

@Deprecated
public RetryDecision onErrorResponse(@NonNull
                                                 Request request,
                                                 @NonNull
                                                 CoordinatorException error,
                                                 int retryCount)

Deprecated.

Specified by:

onErrorResponse in interface RetryPolicy

close

public void close()

Specified by:

close in interface RetryPolicy

Specified by:

close in interface AutoCloseable