[Rename] o.e.cluster.ack,action,block,coordination (#278)
This commit refactors the following: * o.e.cluster.ack * o.e.cluster.action * o.e.cluster.block * o.e.cluster.coordination to o.opensearch package. all other references are also refactored. Signed-off-by: Nicholas Knize <nknize@amazon.com>
This commit is contained in:
parent
c17b34c1dc
commit
2dd77e20aa
|
@ -1,5 +1,5 @@
|
|||
#!/bin/bash
|
||||
|
||||
ES_MAIN_CLASS=org.elasticsearch.cluster.coordination.NodeToolCli \
|
||||
"`dirname "$0"`"/elasticsearch-cli \
|
||||
ES_MAIN_CLASS=org.opensearch.cluster.coordination.NodeToolCli \
|
||||
"`dirname "$0"`"/opensearch-cli \
|
||||
"$@"
|
||||
|
|
|
@ -3,8 +3,8 @@
|
|||
setlocal enabledelayedexpansion
|
||||
setlocal enableextensions
|
||||
|
||||
set ES_MAIN_CLASS=org.elasticsearch.cluster.coordination.NodeToolCli
|
||||
call "%~dp0elasticsearch-cli.bat" ^
|
||||
set ES_MAIN_CLASS=org.opensearch.cluster.coordination.NodeToolCli
|
||||
call "%~dp0opensearch-cli.bat" ^
|
||||
%%* ^
|
||||
|| goto exit
|
||||
|
||||
|
|
|
@ -41,7 +41,7 @@ import org.elasticsearch.action.support.single.shard.SingleShardRequest;
|
|||
import org.elasticsearch.action.support.single.shard.TransportSingleShardAction;
|
||||
import org.elasticsearch.client.node.NodeClient;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.routing.ShardsIterator;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.elasticsearch.OpenSearchException;
|
|||
import org.opensearch.action.OriginalIndices;
|
||||
import org.elasticsearch.action.search.SearchPhaseExecutionException;
|
||||
import org.elasticsearch.action.search.ShardSearchFailure;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.coordination.NoMasterBlockService;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.coordination.NoMasterBlockService;
|
||||
import org.elasticsearch.common.ParsingException;
|
||||
import org.elasticsearch.common.breaker.CircuitBreaker;
|
||||
import org.elasticsearch.common.breaker.CircuitBreakingException;
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
package org.elasticsearch;
|
||||
|
||||
import org.elasticsearch.action.support.replication.ReplicationOperation;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.common.CheckedFunction;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
import org.elasticsearch.common.ParseField;
|
||||
|
@ -750,8 +750,8 @@ public class OpenSearchException extends RuntimeException implements ToXContentF
|
|||
org.elasticsearch.http.BindHttpException::new, 7, UNKNOWN_VERSION_ADDED),
|
||||
REDUCE_SEARCH_PHASE_EXCEPTION(org.elasticsearch.action.search.ReduceSearchPhaseException.class,
|
||||
org.elasticsearch.action.search.ReduceSearchPhaseException::new, 8, UNKNOWN_VERSION_ADDED),
|
||||
NODE_CLOSED_EXCEPTION(org.elasticsearch.node.NodeClosedException.class,
|
||||
org.elasticsearch.node.NodeClosedException::new, 9, UNKNOWN_VERSION_ADDED),
|
||||
NODE_CLOSED_EXCEPTION(org.opensearch.node.NodeClosedException.class,
|
||||
org.opensearch.node.NodeClosedException::new, 9, UNKNOWN_VERSION_ADDED),
|
||||
SNAPSHOT_FAILED_ENGINE_EXCEPTION(org.elasticsearch.index.engine.SnapshotFailedEngineException.class,
|
||||
org.elasticsearch.index.engine.SnapshotFailedEngineException::new, 10, UNKNOWN_VERSION_ADDED),
|
||||
SHARD_NOT_FOUND_EXCEPTION(org.elasticsearch.index.shard.ShardNotFoundException.class,
|
||||
|
@ -826,8 +826,8 @@ public class OpenSearchException extends RuntimeException implements ToXContentF
|
|||
// 47 used to be for IndexTemplateAlreadyExistsException which was deprecated in 5.1 removed in 6.0
|
||||
TRANSLOG_CORRUPTED_EXCEPTION(org.elasticsearch.index.translog.TranslogCorruptedException.class,
|
||||
org.elasticsearch.index.translog.TranslogCorruptedException::new, 48, UNKNOWN_VERSION_ADDED),
|
||||
CLUSTER_BLOCK_EXCEPTION(org.elasticsearch.cluster.block.ClusterBlockException.class,
|
||||
org.elasticsearch.cluster.block.ClusterBlockException::new, 49, UNKNOWN_VERSION_ADDED),
|
||||
CLUSTER_BLOCK_EXCEPTION(org.opensearch.cluster.block.ClusterBlockException.class,
|
||||
org.opensearch.cluster.block.ClusterBlockException::new, 49, UNKNOWN_VERSION_ADDED),
|
||||
FETCH_PHASE_EXECUTION_EXCEPTION(org.elasticsearch.search.fetch.FetchPhaseExecutionException.class,
|
||||
org.elasticsearch.search.fetch.FetchPhaseExecutionException::new, 50, UNKNOWN_VERSION_ADDED),
|
||||
// 51 used to be for IndexShardAlreadyExistsException which was deprecated in 5.1 removed in 6.0
|
||||
|
@ -983,8 +983,8 @@ public class OpenSearchException extends RuntimeException implements ToXContentF
|
|||
UNKNOWN_VERSION_ADDED),
|
||||
TYPE_MISSING_EXCEPTION(org.elasticsearch.indices.TypeMissingException.class,
|
||||
org.elasticsearch.indices.TypeMissingException::new, 137, UNKNOWN_VERSION_ADDED),
|
||||
FAILED_TO_COMMIT_CLUSTER_STATE_EXCEPTION(org.elasticsearch.cluster.coordination.FailedToCommitClusterStateException.class,
|
||||
org.elasticsearch.cluster.coordination.FailedToCommitClusterStateException::new, 140, UNKNOWN_VERSION_ADDED),
|
||||
FAILED_TO_COMMIT_CLUSTER_STATE_EXCEPTION(org.opensearch.cluster.coordination.FailedToCommitClusterStateException.class,
|
||||
org.opensearch.cluster.coordination.FailedToCommitClusterStateException::new, 140, UNKNOWN_VERSION_ADDED),
|
||||
QUERY_SHARD_EXCEPTION(org.elasticsearch.index.query.QueryShardException.class,
|
||||
org.elasticsearch.index.query.QueryShardException::new, 141, UNKNOWN_VERSION_ADDED),
|
||||
NO_LONGER_PRIMARY_SHARD_EXCEPTION(ShardStateAction.NoLongerPrimaryShardException.class,
|
||||
|
@ -1002,8 +1002,8 @@ public class OpenSearchException extends RuntimeException implements ToXContentF
|
|||
// 148 was UnknownNamedObjectException
|
||||
TOO_MANY_BUCKETS_EXCEPTION(MultiBucketConsumerService.TooManyBucketsException.class,
|
||||
MultiBucketConsumerService.TooManyBucketsException::new, 149, Version.V_6_2_0),
|
||||
COORDINATION_STATE_REJECTED_EXCEPTION(org.elasticsearch.cluster.coordination.CoordinationStateRejectedException.class,
|
||||
org.elasticsearch.cluster.coordination.CoordinationStateRejectedException::new, 150, Version.V_7_0_0),
|
||||
COORDINATION_STATE_REJECTED_EXCEPTION(org.opensearch.cluster.coordination.CoordinationStateRejectedException.class,
|
||||
org.opensearch.cluster.coordination.CoordinationStateRejectedException::new, 150, Version.V_7_0_0),
|
||||
SNAPSHOT_IN_PROGRESS_EXCEPTION(org.opensearch.snapshots.SnapshotInProgressException.class,
|
||||
org.opensearch.snapshots.SnapshotInProgressException::new, 151, Version.V_6_7_0),
|
||||
NO_SUCH_REMOTE_CLUSTER_EXCEPTION(org.elasticsearch.transport.NoSuchRemoteClusterException.class,
|
||||
|
@ -1039,8 +1039,8 @@ public class OpenSearchException extends RuntimeException implements ToXContentF
|
|||
158,
|
||||
Version.V_7_9_0),
|
||||
NODE_HEALTH_CHECK_FAILURE_EXCEPTION(
|
||||
org.elasticsearch.cluster.coordination.NodeHealthCheckFailureException.class,
|
||||
org.elasticsearch.cluster.coordination.NodeHealthCheckFailureException::new,
|
||||
org.opensearch.cluster.coordination.NodeHealthCheckFailureException.class,
|
||||
org.opensearch.cluster.coordination.NodeHealthCheckFailureException::new,
|
||||
159,
|
||||
Version.V_7_9_0),
|
||||
NO_SEED_NODE_LEFT_EXCEPTION(
|
||||
|
|
|
@ -30,8 +30,8 @@ import org.opensearch.action.support.ActionFilters;
|
|||
import org.opensearch.action.support.ChannelActionListener;
|
||||
import org.opensearch.action.support.HandledTransportAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
|
|
|
@ -24,7 +24,7 @@ import org.opensearch.action.RoutingMissingException;
|
|||
import org.opensearch.action.support.ActionFilters;
|
||||
import org.opensearch.action.support.HandledTransportAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.opensearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
import org.elasticsearch.common.io.stream.StreamInput;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.opensearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -28,8 +28,8 @@ import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
|||
import org.elasticsearch.client.OriginSettingClient;
|
||||
import org.elasticsearch.client.node.NodeClient;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -25,8 +25,8 @@ import org.elasticsearch.action.support.replication.ReplicationOperation;
|
|||
import org.elasticsearch.action.support.replication.ReplicationResponse;
|
||||
import org.elasticsearch.action.support.replication.TransportReplicationAction;
|
||||
import org.elasticsearch.action.support.replication.TransportWriteAction;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.routing.ShardRouting;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -24,7 +24,7 @@ import org.opensearch.action.support.ActionFilters;
|
|||
import org.opensearch.action.support.HandledTransportAction;
|
||||
import org.elasticsearch.client.node.NodeClient;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
|
|
@ -32,8 +32,8 @@ import org.elasticsearch.client.Client;
|
|||
import org.elasticsearch.client.OriginSettingClient;
|
||||
import org.elasticsearch.client.node.NodeClient;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.opensearch.action.support.ActionFilters;
|
|||
import org.opensearch.action.support.HandledTransportAction;
|
||||
import org.opensearch.action.support.TransportActions;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
|
|
|
@ -33,7 +33,7 @@ import org.elasticsearch.action.support.broadcast.BroadcastRequest;
|
|||
import org.elasticsearch.action.support.broadcast.BroadcastResponse;
|
||||
import org.elasticsearch.action.support.broadcast.BroadcastShardOperationFailedException;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
|
|
|
@ -18,7 +18,7 @@
|
|||
*/
|
||||
package org.elasticsearch.action.support.master;
|
||||
|
||||
import org.elasticsearch.cluster.ack.AckedRequest;
|
||||
import org.opensearch.cluster.ack.AckedRequest;
|
||||
import org.elasticsearch.common.io.stream.StreamInput;
|
||||
import org.elasticsearch.common.io.stream.StreamOutput;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
|
|
|
@ -32,8 +32,8 @@ import org.opensearch.cluster.ClusterState;
|
|||
import org.opensearch.cluster.ClusterStateObserver;
|
||||
import org.opensearch.cluster.MasterNodeChangePredicate;
|
||||
import org.opensearch.cluster.NotMasterException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.coordination.FailedToCommitClusterStateException;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.coordination.FailedToCommitClusterStateException;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.ActionResponse;
|
|||
import org.opensearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.io.stream.Writeable;
|
||||
|
|
|
@ -29,7 +29,7 @@ import org.opensearch.action.UnavailableShardsException;
|
|||
import org.opensearch.action.support.ActiveShardCount;
|
||||
import org.opensearch.action.support.RetryableAction;
|
||||
import org.opensearch.action.support.TransportActions;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.routing.IndexShardRoutingTable;
|
||||
import org.elasticsearch.cluster.routing.ShardRouting;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
|
|
|
@ -37,9 +37,9 @@ import org.opensearch.action.support.TransportActions;
|
|||
import org.elasticsearch.client.transport.NoNodeAvailableException;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateObserver;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.routing.AllocationId;
|
||||
|
|
|
@ -27,8 +27,8 @@ import org.opensearch.action.support.ActionFilters;
|
|||
import org.opensearch.action.support.TransportActions;
|
||||
import org.opensearch.action.support.WriteRequest;
|
||||
import org.opensearch.action.support.WriteResponse;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexAbstraction;
|
||||
import org.elasticsearch.cluster.routing.ShardRouting;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -26,8 +26,8 @@ import org.opensearch.action.support.ActionFilters;
|
|||
import org.opensearch.action.support.HandledTransportAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateObserver;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.routing.ShardIterator;
|
||||
|
|
|
@ -29,8 +29,8 @@ import org.opensearch.action.support.ChannelActionListener;
|
|||
import org.opensearch.action.support.TransportAction;
|
||||
import org.opensearch.action.support.TransportActions;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
|
|
|
@ -24,7 +24,7 @@ import org.opensearch.action.RoutingMissingException;
|
|||
import org.opensearch.action.support.ActionFilters;
|
||||
import org.opensearch.action.support.HandledTransportAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -23,7 +23,7 @@ import org.apache.logging.log4j.LogManager;
|
|||
import org.apache.logging.log4j.Logger;
|
||||
import org.apache.logging.log4j.message.ParameterizedMessage;
|
||||
import org.apache.lucene.util.Constants;
|
||||
import org.elasticsearch.cluster.coordination.ClusterBootstrapService;
|
||||
import org.opensearch.cluster.coordination.ClusterBootstrapService;
|
||||
import org.elasticsearch.common.SuppressForbidden;
|
||||
import org.elasticsearch.common.io.PathUtils;
|
||||
import org.elasticsearch.common.settings.Setting;
|
||||
|
@ -51,7 +51,7 @@ import java.util.regex.Pattern;
|
|||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
|
||||
import static org.elasticsearch.cluster.coordination.ClusterBootstrapService.INITIAL_MASTER_NODES_SETTING;
|
||||
import static org.opensearch.cluster.coordination.ClusterBootstrapService.INITIAL_MASTER_NODES_SETTING;
|
||||
import static org.elasticsearch.discovery.DiscoveryModule.DISCOVERY_SEED_PROVIDERS_SETTING;
|
||||
import static org.elasticsearch.discovery.SettingsBasedSeedHostsProvider.DISCOVERY_SEED_HOSTS_SETTING;
|
||||
|
||||
|
|
|
@ -30,8 +30,8 @@ import org.opensearch.action.support.ActiveShardCount;
|
|||
import org.opensearch.cluster.Diff;
|
||||
import org.opensearch.cluster.Diffable;
|
||||
import org.opensearch.cluster.DiffableUtils;
|
||||
import org.elasticsearch.cluster.block.ClusterBlock;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlock;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodeFilters;
|
||||
import org.elasticsearch.cluster.routing.allocation.IndexMetadataUpdater;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
|
|
|
@ -35,9 +35,9 @@ import org.opensearch.cluster.Diffable;
|
|||
import org.opensearch.cluster.DiffableUtils;
|
||||
import org.opensearch.cluster.NamedDiffable;
|
||||
import org.opensearch.cluster.NamedDiffableValueSerializer;
|
||||
import org.elasticsearch.cluster.block.ClusterBlock;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.opensearch.cluster.block.ClusterBlock;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
import org.elasticsearch.common.Strings;
|
||||
import org.elasticsearch.common.UUIDs;
|
||||
|
|
|
@ -30,8 +30,8 @@ import org.elasticsearch.action.support.ActiveShardsObserver;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateRequest;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateRequest;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.Priority;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
|
|
|
@ -35,11 +35,11 @@ import org.opensearch.action.support.ActiveShardCount;
|
|||
import org.opensearch.action.support.ActiveShardsObserver;
|
||||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.ack.CreateIndexClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.block.ClusterBlock;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.block.ClusterBlocks;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.ack.CreateIndexClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.block.ClusterBlock;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlocks;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
import org.elasticsearch.cluster.routing.IndexRoutingTable;
|
||||
import org.elasticsearch.cluster.routing.RoutingTable;
|
||||
|
|
|
@ -26,8 +26,8 @@ import org.opensearch.action.admin.indices.delete.DeleteIndexClusterStateUpdateR
|
|||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.RestoreInProgress;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.block.ClusterBlocks;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.block.ClusterBlocks;
|
||||
import org.elasticsearch.cluster.routing.RoutingTable;
|
||||
import org.elasticsearch.cluster.routing.allocation.AllocationService;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -24,7 +24,7 @@ import org.opensearch.action.ActionListener;
|
|||
import org.opensearch.action.admin.indices.alias.IndicesAliasesClusterStateUpdateRequest;
|
||||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.metadata.AliasAction.NewAliasValidator;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.Priority;
|
||||
|
|
|
@ -44,11 +44,11 @@ import org.elasticsearch.action.support.replication.ReplicationResponse;
|
|||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateUpdateTask;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.ack.OpenIndexClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.block.ClusterBlock;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.block.ClusterBlocks;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.ack.OpenIndexClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.block.ClusterBlock;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlocks;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata.APIBlock;
|
||||
import org.elasticsearch.cluster.routing.IndexRoutingTable;
|
||||
import org.elasticsearch.cluster.routing.IndexShardRoutingTable;
|
||||
|
|
|
@ -28,7 +28,7 @@ import org.opensearch.cluster.AckedClusterStateTaskListener;
|
|||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateTaskConfig;
|
||||
import org.opensearch.cluster.ClusterStateTaskExecutor;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
|
|
|
@ -28,9 +28,9 @@ import org.opensearch.action.admin.indices.settings.put.UpdateSettingsClusterSta
|
|||
import org.opensearch.action.admin.indices.upgrade.post.UpgradeSettingsClusterStateUpdateRequest;
|
||||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.block.ClusterBlock;
|
||||
import org.elasticsearch.cluster.block.ClusterBlocks;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.block.ClusterBlock;
|
||||
import org.opensearch.cluster.block.ClusterBlocks;
|
||||
import org.elasticsearch.cluster.routing.RoutingTable;
|
||||
import org.elasticsearch.cluster.routing.allocation.AllocationService;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -31,7 +31,7 @@ import org.elasticsearch.client.Client;
|
|||
import org.opensearch.cluster.ClusterInfo;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.DiskUsage;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.routing.RerouteService;
|
||||
import org.elasticsearch.cluster.routing.RoutingNode;
|
||||
|
|
|
@ -32,8 +32,8 @@ import org.opensearch.cluster.ClusterStateTaskConfig;
|
|||
import org.opensearch.cluster.ClusterStateTaskExecutor;
|
||||
import org.opensearch.cluster.ClusterStateTaskExecutor.ClusterTasksResult;
|
||||
import org.opensearch.cluster.ClusterStateTaskListener;
|
||||
import org.elasticsearch.cluster.coordination.ClusterStatePublisher;
|
||||
import org.elasticsearch.cluster.coordination.FailedToCommitClusterStateException;
|
||||
import org.opensearch.cluster.coordination.ClusterStatePublisher;
|
||||
import org.opensearch.cluster.coordination.FailedToCommitClusterStateException;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.metadata.ProcessClusterEventTimeoutException;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
|
|
|
@ -33,19 +33,19 @@ import org.opensearch.cluster.ClusterModule;
|
|||
import org.opensearch.cluster.ClusterName;
|
||||
import org.opensearch.cluster.InternalClusterInfoService;
|
||||
import org.opensearch.cluster.NodeConnectionsService;
|
||||
import org.elasticsearch.cluster.action.index.MappingUpdatedAction;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.coordination.ClusterBootstrapService;
|
||||
import org.elasticsearch.cluster.coordination.ClusterFormationFailureHelper;
|
||||
import org.elasticsearch.cluster.coordination.Coordinator;
|
||||
import org.elasticsearch.cluster.coordination.DiscoveryUpgradeService;
|
||||
import org.elasticsearch.cluster.coordination.ElectionSchedulerFactory;
|
||||
import org.elasticsearch.cluster.coordination.FollowersChecker;
|
||||
import org.elasticsearch.cluster.coordination.JoinHelper;
|
||||
import org.elasticsearch.cluster.coordination.LagDetector;
|
||||
import org.elasticsearch.cluster.coordination.LeaderChecker;
|
||||
import org.elasticsearch.cluster.coordination.NoMasterBlockService;
|
||||
import org.elasticsearch.cluster.coordination.Reconfigurator;
|
||||
import org.opensearch.cluster.action.index.MappingUpdatedAction;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.coordination.ClusterBootstrapService;
|
||||
import org.opensearch.cluster.coordination.ClusterFormationFailureHelper;
|
||||
import org.opensearch.cluster.coordination.Coordinator;
|
||||
import org.opensearch.cluster.coordination.DiscoveryUpgradeService;
|
||||
import org.opensearch.cluster.coordination.ElectionSchedulerFactory;
|
||||
import org.opensearch.cluster.coordination.FollowersChecker;
|
||||
import org.opensearch.cluster.coordination.JoinHelper;
|
||||
import org.opensearch.cluster.coordination.LagDetector;
|
||||
import org.opensearch.cluster.coordination.LeaderChecker;
|
||||
import org.opensearch.cluster.coordination.NoMasterBlockService;
|
||||
import org.opensearch.cluster.coordination.Reconfigurator;
|
||||
import org.elasticsearch.cluster.metadata.IndexGraveyard;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.routing.OperationRouting;
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.discovery;
|
||||
|
||||
import org.elasticsearch.cluster.coordination.ClusterStatePublisher;
|
||||
import org.opensearch.cluster.coordination.ClusterStatePublisher;
|
||||
import org.elasticsearch.common.component.LifecycleComponent;
|
||||
|
||||
/**
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.apache.logging.log4j.LogManager;
|
|||
import org.apache.logging.log4j.Logger;
|
||||
import org.elasticsearch.Assertions;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.coordination.Coordinator;
|
||||
import org.elasticsearch.cluster.coordination.ElectionStrategy;
|
||||
import org.opensearch.cluster.coordination.Coordinator;
|
||||
import org.opensearch.cluster.coordination.ElectionStrategy;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.routing.RerouteService;
|
||||
import org.elasticsearch.cluster.routing.allocation.AllocationService;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.apache.lucene.util.SetOnce;
|
|||
import org.opensearch.action.ActionListener;
|
||||
import org.opensearch.cluster.ClusterName;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.coordination.PeersResponse;
|
||||
import org.opensearch.cluster.coordination.PeersResponse;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
|
@ -64,8 +64,8 @@ import java.util.function.Consumer;
|
|||
import java.util.stream.Collectors;
|
||||
|
||||
import static java.util.Collections.emptyList;
|
||||
import static org.elasticsearch.cluster.coordination.Coordinator.isZen1Node;
|
||||
import static org.elasticsearch.cluster.coordination.DiscoveryUpgradeService.createDiscoveryNodeWithImpossiblyHighId;
|
||||
import static org.opensearch.cluster.coordination.Coordinator.isZen1Node;
|
||||
import static org.opensearch.cluster.coordination.DiscoveryUpgradeService.createDiscoveryNodeWithImpossiblyHighId;
|
||||
|
||||
public abstract class PeerFinder {
|
||||
|
||||
|
|
|
@ -22,7 +22,7 @@ package org.elasticsearch.discovery.zen;
|
|||
import org.apache.logging.log4j.LogManager;
|
||||
import org.apache.logging.log4j.Logger;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.coordination.ValidateJoinRequest;
|
||||
import org.opensearch.cluster.coordination.ValidateJoinRequest;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.common.io.stream.StreamInput;
|
||||
import org.elasticsearch.common.io.stream.StreamOutput;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.opensearch.cluster.ClusterState;
|
|||
import org.opensearch.cluster.ClusterStateTaskConfig;
|
||||
import org.opensearch.cluster.ClusterStateTaskListener;
|
||||
import org.opensearch.cluster.NotMasterException;
|
||||
import org.elasticsearch.cluster.coordination.JoinTaskExecutor;
|
||||
import org.opensearch.cluster.coordination.JoinTaskExecutor;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.routing.RerouteService;
|
||||
import org.elasticsearch.cluster.routing.allocation.AllocationService;
|
||||
|
|
|
@ -22,7 +22,7 @@ package org.elasticsearch.discovery.zen;
|
|||
import org.apache.logging.log4j.Logger;
|
||||
import org.elasticsearch.OpenSearchException;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.opensearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
|
||||
|
|
|
@ -47,7 +47,7 @@ import org.elasticsearch.discovery.AckClusterStatePublishResponseHandler;
|
|||
import org.elasticsearch.discovery.BlockingClusterStatePublishResponseHandler;
|
||||
import org.elasticsearch.discovery.Discovery;
|
||||
import org.elasticsearch.discovery.DiscoverySettings;
|
||||
import org.elasticsearch.cluster.coordination.FailedToCommitClusterStateException;
|
||||
import org.opensearch.cluster.coordination.FailedToCommitClusterStateException;
|
||||
import org.opensearch.tasks.Task;
|
||||
import org.opensearch.threadpool.ThreadPool;
|
||||
import org.elasticsearch.transport.BytesTransportRequest;
|
||||
|
|
|
@ -30,11 +30,11 @@ import org.opensearch.cluster.ClusterName;
|
|||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateTaskConfig;
|
||||
import org.opensearch.cluster.NotMasterException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlocks;
|
||||
import org.elasticsearch.cluster.coordination.FailedToCommitClusterStateException;
|
||||
import org.elasticsearch.cluster.coordination.JoinTaskExecutor;
|
||||
import org.elasticsearch.cluster.coordination.NoMasterBlockService;
|
||||
import org.elasticsearch.cluster.coordination.NodeRemovalClusterStateTaskExecutor;
|
||||
import org.opensearch.cluster.block.ClusterBlocks;
|
||||
import org.opensearch.cluster.coordination.FailedToCommitClusterStateException;
|
||||
import org.opensearch.cluster.coordination.JoinTaskExecutor;
|
||||
import org.opensearch.cluster.coordination.NoMasterBlockService;
|
||||
import org.opensearch.cluster.coordination.NodeRemovalClusterStateTaskExecutor;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
import org.elasticsearch.cluster.routing.RerouteService;
|
||||
|
|
|
@ -24,7 +24,7 @@ import joptsimple.OptionSet;
|
|||
import org.elasticsearch.OpenSearchException;
|
||||
import org.opensearch.cli.Terminal;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.coordination.OpenSearchNodeCommand;
|
||||
import org.opensearch.cluster.coordination.OpenSearchNodeCommand;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
|
|
|
@ -23,7 +23,7 @@ import joptsimple.OptionSet;
|
|||
import org.elasticsearch.OpenSearchException;
|
||||
import org.elasticsearch.Version;
|
||||
import org.opensearch.cli.Terminal;
|
||||
import org.elasticsearch.cluster.coordination.OpenSearchNodeCommand;
|
||||
import org.opensearch.cluster.coordination.OpenSearchNodeCommand;
|
||||
import org.elasticsearch.gateway.PersistedClusterStateService;
|
||||
|
||||
import java.io.IOException;
|
||||
|
|
|
@ -24,7 +24,7 @@ import org.apache.logging.log4j.LogManager;
|
|||
import org.apache.logging.log4j.Logger;
|
||||
import org.apache.logging.log4j.message.ParameterizedMessage;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlocks;
|
||||
import org.opensearch.cluster.block.ClusterBlocks;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
|
|
|
@ -31,9 +31,9 @@ import org.opensearch.cluster.ClusterChangedEvent;
|
|||
import org.opensearch.cluster.ClusterName;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateApplier;
|
||||
import org.elasticsearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.elasticsearch.cluster.coordination.CoordinationState.PersistedState;
|
||||
import org.elasticsearch.cluster.coordination.InMemoryPersistedState;
|
||||
import org.opensearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.opensearch.cluster.coordination.CoordinationState.PersistedState;
|
||||
import org.opensearch.cluster.coordination.InMemoryPersistedState;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.metadata.IndexTemplateMetadata;
|
||||
import org.elasticsearch.cluster.metadata.Manifest;
|
||||
|
|
|
@ -26,9 +26,9 @@ import org.opensearch.cluster.ClusterChangedEvent;
|
|||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateListener;
|
||||
import org.opensearch.cluster.ClusterStateUpdateTask;
|
||||
import org.elasticsearch.cluster.block.ClusterBlock;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.coordination.Coordinator;
|
||||
import org.opensearch.cluster.block.ClusterBlock;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.coordination.Coordinator;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
import org.elasticsearch.cluster.routing.allocation.AllocationService;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.opensearch.action.ActionListener;
|
|||
import org.opensearch.action.ActionListenerResponseHandler;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateUpdateTask;
|
||||
import org.elasticsearch.cluster.block.ClusterBlocks;
|
||||
import org.opensearch.cluster.block.ClusterBlocks;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.metadata.MetadataIndexUpgradeService;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.replication.ReplicationRequest;
|
||||
import org.elasticsearch.action.support.replication.ReplicationResponse;
|
||||
import org.elasticsearch.action.support.replication.TransportReplicationAction;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
import org.elasticsearch.common.io.stream.StreamInput;
|
||||
|
|
|
@ -31,7 +31,7 @@ import org.elasticsearch.action.support.replication.ReplicationRequest;
|
|||
import org.elasticsearch.action.support.replication.ReplicationResponse;
|
||||
import org.elasticsearch.action.support.replication.ReplicationTask;
|
||||
import org.elasticsearch.action.support.replication.TransportReplicationAction;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
import org.elasticsearch.common.io.stream.StreamInput;
|
||||
|
|
|
@ -33,8 +33,8 @@ import org.elasticsearch.action.support.replication.ReplicatedWriteRequest;
|
|||
import org.elasticsearch.action.support.replication.ReplicationResponse;
|
||||
import org.elasticsearch.action.support.replication.ReplicationTask;
|
||||
import org.elasticsearch.action.support.replication.TransportWriteAction;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
import org.elasticsearch.common.io.stream.StreamInput;
|
||||
|
|
|
@ -34,7 +34,7 @@ import org.apache.lucene.store.NativeFSLockFactory;
|
|||
import org.elasticsearch.OpenSearchException;
|
||||
import org.opensearch.cli.Terminal;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.coordination.OpenSearchNodeCommand;
|
||||
import org.opensearch.cluster.coordination.OpenSearchNodeCommand;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.routing.AllocationId;
|
||||
import org.elasticsearch.cluster.routing.allocation.command.AllocateEmptyPrimaryAllocationCommand;
|
||||
|
|
|
@ -27,8 +27,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.opensearch.cluster.ClusterChangedEvent;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateApplier;
|
||||
import org.elasticsearch.cluster.action.index.NodeMappingRefreshAction;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.action.index.NodeMappingRefreshAction;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
|
|
|
@ -34,7 +34,7 @@ import org.opensearch.cluster.RepositoryCleanupInProgress;
|
|||
import org.opensearch.cluster.RestoreInProgress;
|
||||
import org.opensearch.cluster.SnapshotDeletionsInProgress;
|
||||
import org.opensearch.cluster.SnapshotsInProgress;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.metadata.RepositoriesMetadata;
|
||||
import org.elasticsearch.cluster.metadata.RepositoryMetadata;
|
||||
|
|
|
@ -27,8 +27,8 @@ import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
|||
import org.opensearch.cluster.ClusterInfo;
|
||||
import org.opensearch.cluster.ClusterInfoService;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.routing.RoutingNodes;
|
||||
|
|
|
@ -22,7 +22,7 @@ import org.elasticsearch.Version;
|
|||
import org.opensearch.action.ActionRequestValidationException;
|
||||
import org.elasticsearch.action.support.master.MasterNodeRequest;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.coordination.CoordinationMetadata.VotingConfigExclusion;
|
||||
import org.opensearch.cluster.coordination.CoordinationMetadata.VotingConfigExclusion;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNodes;
|
||||
import org.elasticsearch.common.Strings;
|
||||
|
|
|
@ -29,10 +29,10 @@ import org.opensearch.cluster.ClusterState;
|
|||
import org.opensearch.cluster.ClusterStateObserver;
|
||||
import org.opensearch.cluster.ClusterStateObserver.Listener;
|
||||
import org.opensearch.cluster.ClusterStateUpdateTask;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.elasticsearch.cluster.coordination.CoordinationMetadata.VotingConfigExclusion;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.opensearch.cluster.coordination.CoordinationMetadata.VotingConfigExclusion;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -29,10 +29,10 @@ import org.opensearch.cluster.ClusterState;
|
|||
import org.opensearch.cluster.ClusterStateObserver;
|
||||
import org.opensearch.cluster.ClusterStateObserver.Listener;
|
||||
import org.opensearch.cluster.ClusterStateUpdateTask;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.elasticsearch.cluster.coordination.CoordinationMetadata.VotingConfigExclusion;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.coordination.CoordinationMetadata;
|
||||
import org.opensearch.cluster.coordination.CoordinationMetadata.VotingConfigExclusion;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -32,7 +32,7 @@ import org.opensearch.cluster.ClusterStateObserver;
|
|||
import org.opensearch.cluster.ClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.LocalClusterUpdateTask;
|
||||
import org.opensearch.cluster.NotMasterException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.health.ClusterHealthStatus;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.ProcessClusterEventTimeoutException;
|
||||
|
|
|
@ -32,8 +32,8 @@ import org.opensearch.cluster.ClusterStateUpdateTask;
|
|||
import org.opensearch.cluster.RepositoryCleanupInProgress;
|
||||
import org.opensearch.cluster.SnapshotDeletionsInProgress;
|
||||
import org.opensearch.cluster.SnapshotsInProgress;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.metadata.RepositoriesMetadata;
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -32,8 +32,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.routing.allocation.AllocationService;
|
||||
|
|
|
@ -23,7 +23,7 @@ import org.apache.logging.log4j.Logger;
|
|||
import org.apache.logging.log4j.message.ParameterizedMessage;
|
||||
import org.apache.logging.log4j.util.Supplier;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlocks;
|
||||
import org.opensearch.cluster.block.ClusterBlocks;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.common.collect.Tuple;
|
||||
import org.elasticsearch.common.settings.ClusterSettings;
|
||||
|
|
|
@ -28,8 +28,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.cluster.routing.GroupShardsIterator;
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -29,8 +29,8 @@ import org.elasticsearch.action.support.PlainActionFuture;
|
|||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.SnapshotsInProgress;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -30,8 +30,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.SnapshotsInProgress;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -28,7 +28,7 @@ import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
|||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateObserver;
|
||||
import org.opensearch.cluster.NotMasterException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -25,7 +25,7 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.cluster.service.PendingClusterTask;
|
||||
|
|
|
@ -18,7 +18,7 @@
|
|||
*/
|
||||
package org.opensearch.action.admin.indices.alias;
|
||||
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateRequest;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateRequest;
|
||||
import org.elasticsearch.cluster.metadata.AliasAction;
|
||||
|
||||
import java.util.List;
|
||||
|
|
|
@ -28,9 +28,9 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.AliasAction;
|
||||
import org.elasticsearch.cluster.metadata.AliasMetadata;
|
||||
import org.elasticsearch.cluster.metadata.IndexAbstraction;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.admin.indices.alias.get.GetAliasesRequest;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
|
|
|
@ -22,8 +22,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.AliasMetadata;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
|
|
|
@ -31,7 +31,7 @@ import org.elasticsearch.OpenSearchException;
|
|||
import org.opensearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.single.shard.TransportSingleShardAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.routing.ShardsIterator;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.DefaultShardOperationFailedException;
|
||||
import org.elasticsearch.action.support.broadcast.node.TransportBroadcastByNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.routing.ShardRouting;
|
||||
import org.elasticsearch.cluster.routing.ShardsIterator;
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
package org.opensearch.action.admin.indices.close;
|
||||
|
||||
import org.opensearch.action.support.ActiveShardCount;
|
||||
import org.elasticsearch.cluster.ack.IndicesClusterStateUpdateRequest;
|
||||
import org.opensearch.cluster.ack.IndicesClusterStateUpdateRequest;
|
||||
|
||||
/**
|
||||
* Cluster state update request that allows to close one or more indices
|
||||
|
|
|
@ -27,8 +27,8 @@ import org.elasticsearch.action.support.ActionFilters;
|
|||
import org.elasticsearch.action.support.DestructiveOperations;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.MetadataIndexStateService;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -28,9 +28,9 @@ import org.elasticsearch.action.support.replication.ReplicationOperation;
|
|||
import org.elasticsearch.action.support.replication.ReplicationRequest;
|
||||
import org.elasticsearch.action.support.replication.ReplicationResponse;
|
||||
import org.elasticsearch.action.support.replication.TransportReplicationAction;
|
||||
import org.elasticsearch.cluster.action.shard.ShardStateAction;
|
||||
import org.elasticsearch.cluster.block.ClusterBlock;
|
||||
import org.elasticsearch.cluster.block.ClusterBlocks;
|
||||
import org.opensearch.cluster.action.shard.ShardStateAction;
|
||||
import org.opensearch.cluster.block.ClusterBlock;
|
||||
import org.opensearch.cluster.block.ClusterBlocks;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.common.inject.Inject;
|
||||
import org.elasticsearch.common.io.stream.StreamInput;
|
||||
|
|
|
@ -26,9 +26,9 @@ import org.elasticsearch.action.support.ActiveShardsObserver;
|
|||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateResponse;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.ComposableIndexTemplate;
|
||||
import org.elasticsearch.cluster.metadata.ComposableIndexTemplate.DataStreamTemplate;
|
||||
|
|
|
@ -22,8 +22,8 @@ package org.opensearch.action.admin.indices.create;
|
|||
import org.opensearch.action.admin.indices.alias.Alias;
|
||||
import org.opensearch.action.admin.indices.shrink.ResizeType;
|
||||
import org.opensearch.action.support.ActiveShardCount;
|
||||
import org.elasticsearch.cluster.ack.ClusterStateUpdateRequest;
|
||||
import org.elasticsearch.cluster.block.ClusterBlock;
|
||||
import org.opensearch.cluster.ack.ClusterStateUpdateRequest;
|
||||
import org.opensearch.cluster.block.ClusterBlock;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.index.Index;
|
||||
|
|
|
@ -23,8 +23,8 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.action.support.ActionFilters;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.MetadataCreateIndexService;
|
||||
import org.elasticsearch.cluster.service.ClusterService;
|
||||
|
|
|
@ -36,7 +36,7 @@ import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
|||
import org.elasticsearch.client.node.NodeClient;
|
||||
import org.opensearch.cluster.AckedClusterStateUpdateTask;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.metadata.IndexGraveyard;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
|
|
|
@ -29,8 +29,8 @@ import org.elasticsearch.action.support.master.AcknowledgedRequest;
|
|||
import org.elasticsearch.action.support.master.AcknowledgedResponse;
|
||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.MetadataCreateDataStreamService;
|
||||
import org.elasticsearch.cluster.metadata.MetadataCreateDataStreamService.CreateDataStreamClusterStateUpdateRequest;
|
||||
|
|
|
@ -29,8 +29,8 @@ import org.elasticsearch.action.support.broadcast.BroadcastRequest;
|
|||
import org.elasticsearch.action.support.broadcast.BroadcastResponse;
|
||||
import org.elasticsearch.action.support.broadcast.node.TransportBroadcastByNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.IndexAbstraction;
|
||||
import org.elasticsearch.cluster.metadata.IndexAbstractionResolver;
|
||||
import org.elasticsearch.cluster.metadata.IndexMetadata;
|
||||
|
|
|
@ -31,8 +31,8 @@ import org.elasticsearch.action.support.master.MasterNodeRequest;
|
|||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.ClusterStateUpdateTask;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.metadata.DataStream;
|
||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||
import org.elasticsearch.cluster.metadata.Metadata;
|
||||
|
|
|
@ -31,8 +31,8 @@ import org.elasticsearch.action.support.master.MasterNodeReadRequest;
|
|||
import org.elasticsearch.action.support.master.TransportMasterNodeReadAction;
|
||||
import org.opensearch.cluster.AbstractDiffable;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||
import org.opensearch.cluster.block.ClusterBlockException;
|
||||
import org.opensearch.cluster.block.ClusterBlockLevel;
|
||||
import org.elasticsearch.cluster.health.ClusterHealthStatus;
|
||||
import org.elasticsearch.cluster.health.ClusterStateHealth;
|
||||
import org.elasticsearch.cluster.metadata.DataStream;
|
||||
|
|
|
@ -18,7 +18,7 @@
|
|||
*/
|
||||
package org.opensearch.action.admin.indices.delete;
|
||||
|
||||
import org.elasticsearch.cluster.ack.IndicesClusterStateUpdateRequest;
|
||||
import org.opensearch.cluster.ack.IndicesClusterStateUpdateRequest;
|
||||
|
||||
/**
|
||||
* Cluster state update request that allows to close one or more indices
|
||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue