override def onReadTimeout()

in driver/src/main/scala/com/datastax/spark/connector/cql/MultipleRetryPolicy.scala [49:82]

• 29 lines of code
• 1 McCabe index (conditional complexity)

  override def onReadTimeout(
    request: Request,
    cl: ConsistencyLevel,
    blockFor: Int,
    received: Int,
    dataPresent: Boolean,
    retryCount: Int): RetryDecision = retryManyTimesOrThrow(retryCount)

  override def onWriteTimeout(
    request: Request,
    cl: ConsistencyLevel,
    writeType: WriteType,
    blockFor: Int,
    received: Int,
    retryCount: Int): RetryDecision = retryManyTimesOrThrow(retryCount)

  override def onUnavailable(
    request: Request,
    cl: ConsistencyLevel,
    required: Int,
    alive: Int,
    retryCount: Int): RetryDecision = retryManyTimesOrThrow(retryCount)

  override def onRequestAborted(
    request: Request,
    error: Throwable,
    retryCount: Int): RetryDecision = retryManyTimesOrThrow(retryCount)

  override def onErrorResponse(
    request: Request,
    error: CoordinatorException,
    retryCount: Int): RetryDecision = RetryDecision.RETHROW

  override def close(): Unit = {}