Class WorkerBulkByScrollTaskState

    • Constructor Detail

      • WorkerBulkByScrollTaskState

        public WorkerBulkByScrollTaskState​(BulkByScrollTask task,
                                           java.lang.Integer sliceId,
                                           float requestsPerSecond)
    • Method Detail

      • handleCancel

        public void handleCancel()
      • setTotal

        public void setTotal​(long totalHits)
      • countBatch

        public void countBatch()
      • countNoop

        public void countNoop()
      • countCreated

        public void countCreated()
      • countUpdated

        public void countUpdated()
      • countDeleted

        public void countDeleted()
      • countVersionConflict

        public void countVersionConflict()
      • countBulkRetry

        public void countBulkRetry()
      • countSearchRetry

        public void countSearchRetry()
      • delayPrepareBulkRequest

        public void delayPrepareBulkRequest​(ThreadPool threadPool,
                                            long lastBatchStartTimeNS,
                                            int lastBatchSize,
                                            AbstractRunnable prepareBulkRequestRunnable)
        Schedule prepareBulkRequestRunnable to run after some delay. This is where throttling plugs into reindexing so the request can be rescheduled over and over again.
      • throttleWaitTime

        public TimeValue throttleWaitTime​(long lastBatchStartTimeNS,
                                          long nowNS,
                                          int lastBatchSize)
      • rethrottle

        public void rethrottle​(float newRequestsPerSecond)
        Apply newRequestsPerSecond as the new rate limit for this task's search requests