fix line length in RolloverStep

This commit is contained in:
Tal Levy 2018-04-27 07:48:17 -07:00
parent ec9f1a9f3b
commit f6a425e676
1 changed files with 8 additions and 7 deletions

View File

@ -36,8 +36,9 @@ public class RolloverStep extends AsyncActionStep {
String rolloverAlias = RolloverAction.LIFECYCLE_ROLLOVER_ALIAS_SETTING.get(indexMetaData.getSettings()); String rolloverAlias = RolloverAction.LIFECYCLE_ROLLOVER_ALIAS_SETTING.get(indexMetaData.getSettings());
if (Strings.isNullOrEmpty(rolloverAlias)) { if (Strings.isNullOrEmpty(rolloverAlias)) {
listener.onFailure(new IllegalArgumentException(String.format(Locale.ROOT, "setting [%s] for index [%s] is empty or not defined", listener.onFailure(new IllegalArgumentException(String.format(Locale.ROOT,
RolloverAction.LIFECYCLE_ROLLOVER_ALIAS, indexMetaData.getIndex().getName()))); "setting [%s] for index [%s] is empty or not defined", RolloverAction.LIFECYCLE_ROLLOVER_ALIAS,
indexMetaData.getIndex().getName())));
return; return;
} }
@ -54,24 +55,24 @@ public class RolloverStep extends AsyncActionStep {
getClient().admin().indices().rolloverIndex(rolloverRequest, getClient().admin().indices().rolloverIndex(rolloverRequest,
ActionListener.wrap(response -> listener.onResponse(response.isRolledOver()), listener::onFailure)); ActionListener.wrap(response -> listener.onResponse(response.isRolledOver()), listener::onFailure));
} }
ByteSizeValue getMaxSize() { ByteSizeValue getMaxSize() {
return maxSize; return maxSize;
} }
TimeValue getMaxAge() { TimeValue getMaxAge() {
return maxAge; return maxAge;
} }
Long getMaxDocs() { Long getMaxDocs() {
return maxDocs; return maxDocs;
} }
@Override @Override
public int hashCode() { public int hashCode() {
return Objects.hash(super.hashCode(), maxSize, maxAge, maxDocs); return Objects.hash(super.hashCode(), maxSize, maxAge, maxDocs);
} }
@Override @Override
public boolean equals(Object obj) { public boolean equals(Object obj) {
if (obj == null) { if (obj == null) {