Module org.elasticsearch.xcore

Package org.elasticsearch.xpack.core.ilm

Class WaitForRolloverReadyStep

java.lang.Object

org.elasticsearch.xpack.core.ilm.Step

org.elasticsearch.xpack.core.ilm.AsyncWaitStep

org.elasticsearch.xpack.core.ilm.WaitForRolloverReadyStep

public class WaitForRolloverReadyStep
extends AsyncWaitStep

Waits for at least one rollover condition to be satisfied, using the Rollover API's dry_run option.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.xpack.core.ilm.AsyncWaitStep

AsyncWaitStep.Listener

Nested classes/interfaces inherited from class org.elasticsearch.xpack.core.ilm.Step

Step.StepKey

Field Summary

Fields

Modifier and Type	Field	Description
static final long	MAX_PRIMARY_SHARD_DOCS
static final String	NAME

Constructor Summary

Constructors

Constructor	Description
WaitForRolloverReadyStep(Step.StepKey key, Step.StepKey nextStepKey, Client client, RolloverConditions conditions)
WaitForRolloverReadyStep(Step.StepKey key, Step.StepKey nextStepKey, Client client, ByteSizeValue maxSize, ByteSizeValue maxPrimaryShardSize, TimeValue maxAge, Long maxDocs, Long maxPrimaryShardDocs, ByteSizeValue minSize, ByteSizeValue minPrimaryShardSize, TimeValue minAge, Long minDocs, Long minPrimaryShardDocs)

Method Summary

Modifier and Type	Method	Description
static RolloverConditions	applyDefaultConditions(RolloverConditions conditions, boolean rolloverOnlyIfHasDocuments)	Apply default conditions to the set of user-defined conditions.
boolean	equals(Object obj)
void	evaluateCondition(ProjectState state, IndexMetadata indexMetadata, AsyncWaitStep.Listener listener, TimeValue masterTimeout)
RolloverConditions	getConditions()
int	hashCode()
boolean	isRetryable()	Indicates if the step can be automatically retried when it encounters an execution error.

Methods inherited from class org.elasticsearch.xpack.core.ilm.AsyncWaitStep

getClient

Methods inherited from class org.elasticsearch.xpack.core.ilm.Step

getCurrentStepKey, getKey, getNextStepKey, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

MAX_PRIMARY_SHARD_DOCS

public static final long MAX_PRIMARY_SHARD_DOCS

See Also:

• Constant Field Values

Constructor Details

WaitForRolloverReadyStep

public WaitForRolloverReadyStep(Step.StepKey key,
 Step.StepKey nextStepKey,
 Client client,
 ByteSizeValue maxSize,
 ByteSizeValue maxPrimaryShardSize,
 TimeValue maxAge,
 Long maxDocs,
 Long maxPrimaryShardDocs,
 ByteSizeValue minSize,
 ByteSizeValue minPrimaryShardSize,
 TimeValue minAge,
 Long minDocs,
 Long minPrimaryShardDocs)

WaitForRolloverReadyStep

public WaitForRolloverReadyStep(Step.StepKey key,
 Step.StepKey nextStepKey,
 Client client,
 RolloverConditions conditions)

Method Details

isRetryable

public boolean isRetryable()

Description copied from class: Step

Indicates if the step can be automatically retried when it encounters an execution error.

Specified by:

isRetryable in class Step

evaluateCondition

public void evaluateCondition(ProjectState state,
 IndexMetadata indexMetadata,
 AsyncWaitStep.Listener listener,
 TimeValue masterTimeout)

Specified by:

evaluateCondition in class AsyncWaitStep

applyDefaultConditions

public static RolloverConditions applyDefaultConditions(RolloverConditions conditions,
 boolean rolloverOnlyIfHasDocuments)

Apply default conditions to the set of user-defined conditions.

Parameters:

conditions - the existing conditions

rolloverOnlyIfHasDocuments - whether to inject a min_docs 1 condition if there is not already a min_docs (or min_primary_shard_docs) condition

Returns:

the rollover conditions with the default conditions applied.

getConditions

public RolloverConditions getConditions()

hashCode

public int hashCode()

Overrides:

hashCode in class Step

equals

public boolean equals(Object obj)

Overrides:

equals in class Step