Package org.elasticsearch.index.reindex

Class BulkByScrollTask.Status

    • Field Detail

      • INCLUDE_CREATED

        public static final java.lang.String INCLUDE_CREATED
        XContent param name to indicate if "created" count must be included in the response.
        See Also:
        Constant Field Values

      • INCLUDE_UPDATED

        public static final java.lang.String INCLUDE_UPDATED
        XContent param name to indicate if "updated" count must be included in the response.
        See Also:
        Constant Field Values

      • VERSION_CONFLICTS_FIELD

        public static final java.lang.String VERSION_CONFLICTS_FIELD
        See Also:
        Constant Field Values

      • RETRIES_BULK_FIELD

        public static final java.lang.String RETRIES_BULK_FIELD
        See Also:
        Constant Field Values

      • RETRIES_SEARCH_FIELD

        public static final java.lang.String RETRIES_SEARCH_FIELD
        See Also:
        Constant Field Values

      • THROTTLED_RAW_FIELD

        public static final java.lang.String THROTTLED_RAW_FIELD
        See Also:
        Constant Field Values

      • THROTTLED_HR_FIELD

        public static final java.lang.String THROTTLED_HR_FIELD
        See Also:
        Constant Field Values

      • REQUESTS_PER_SEC_FIELD

        public static final java.lang.String REQUESTS_PER_SEC_FIELD
        See Also:
        Constant Field Values

      • THROTTLED_UNTIL_RAW_FIELD

        public static final java.lang.String THROTTLED_UNTIL_RAW_FIELD
        See Also:
        Constant Field Values

      • THROTTLED_UNTIL_HR_FIELD

        public static final java.lang.String THROTTLED_UNTIL_HR_FIELD
        See Also:
        Constant Field Values

      • FIELDS_SET

        public static java.util.Set<java.lang.String> FIELDS_SET

    • Constructor Detail

      • Status

        public Status​(java.lang.Integer sliceId,
              long total,
              long updated,
              long created,
              long deleted,
              int batches,
              long versionConflicts,
              long noops,
              long bulkRetries,
              long searchRetries,
              TimeValue throttled,
              float requestsPerSecond,
              @Nullable
              java.lang.String reasonCancelled,
              TimeValue throttledUntil)

      • Status

        public Status​(java.util.List<BulkByScrollTask.StatusOrException> sliceStatuses,
              @Nullable
              java.lang.String reasonCancelled)
        Constructor merging many statuses.
        Parameters:
        sliceStatuses - Statuses of sub requests that this task was sliced into.
        reasonCancelled - Reason that this *this* task was cancelled. Note that each entry in sliceStatuses can be cancelled independently of this task but if this task is cancelled then the workers *should* be cancelled.

      • Status

        public Status​(StreamInput in)
       throws java.io.IOException
        Throws:
        java.io.IOException

    • Method Detail

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object

      • innerToString

        public void innerToString​(java.lang.StringBuilder builder)

      • getTotal

        public long getTotal()
        The total number of documents this request will process. 0 means we don't yet know or, possibly, there are actually 0 documents to process. Its ok that these have the same meaning because any request with 0 actual documents should be quite short lived.

      • getBatches

        public int getBatches()
        Number of scan responses this request has processed.

      • getVersionConflicts

        public long getVersionConflicts()
        Number of version conflicts this request has hit.

      • getNoops

        public long getNoops()
        Number of noops (skipped bulk items) as part of this request.

      • getBulkRetries

        public long getBulkRetries()
        Number of retries that had to be attempted due to bulk actions being rejected.

      • getSearchRetries

        public long getSearchRetries()
        Number of retries that had to be attempted due to search actions being rejected.

      • getThrottled

        public TimeValue getThrottled()
        The total time this request has throttled itself not including the current throttle time if it is currently sleeping.

      • getRequestsPerSecond

        public float getRequestsPerSecond()
        The number of requests per second to which to throttle the request. Float.POSITIVE_INFINITY means unlimited.

      • getReasonCancelled

        public java.lang.String getReasonCancelled()
        The reason that the request was canceled or null if it hasn't been.

      • getThrottledUntil

        public TimeValue getThrottledUntil()
        Remaining delay of any current throttle sleep or 0 if not sleeping.

      • getSliceStatuses

        public java.util.List<BulkByScrollTask.StatusOrException> getSliceStatuses()
        Statuses of the sub requests into which this sub-request was sliced. Empty if this request wasn't sliced into sub-requests.

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object

      • equalsWithoutSliceStatus

        public boolean equalsWithoutSliceStatus​(java.lang.Object o,
                                        boolean includeUpdated,
                                        boolean includeCreated)

      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object