Rename org.elasticsearch.node to org.opensearch.node

Signed-off-by: Harold Wang <harowang@amazon.com>

server/src/main/java/org/opensearch/action/admin/cluster/node/info/PluginsAndModules.java

@@ -22,7 +22,7 @@
 import org.opensearch.common.io.stream.StreamInput;
 import org.opensearch.common.io.stream.StreamOutput;
 import org.elasticsearch.common.xcontent.XContentBuilder;
-import org.elasticsearch.node.ReportingService;
+import org.opensearch.node.ReportingService;
 import org.opensearch.plugins.PluginInfo;
 
 import java.io.IOException;

server/src/main/java/org/opensearch/action/main/TransportMainAction.java

@@ -28,7 +28,7 @@
 import org.elasticsearch.cluster.service.ClusterService;
 import org.opensearch.common.inject.Inject;
 import org.elasticsearch.common.settings.Settings;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 import org.opensearch.tasks.Task;
 import org.opensearch.transport.TransportService;
 

server/src/main/java/org/opensearch/action/search/SearchExecutionStatsCollector.java

@@ -20,7 +20,7 @@
 package org.opensearch.action.search;
 
 import org.opensearch.action.ActionListener;
-import org.elasticsearch.node.ResponseCollectorService;
+import org.opensearch.node.ResponseCollectorService;
 import org.opensearch.search.SearchPhaseResult;
 import org.opensearch.search.query.QuerySearchResult;
 import org.opensearch.transport.Transport;

server/src/main/java/org/opensearch/action/support/ActiveShardsObserver.java

@@ -26,7 +26,7 @@
 import org.opensearch.cluster.ClusterStateObserver;
 import org.opensearch.cluster.service.ClusterService;
 import org.elasticsearch.common.unit.TimeValue;
-import org.elasticsearch.node.NodeClosedException;
+import org.opensearch.node.NodeClosedException;
 import org.opensearch.threadpool.ThreadPool;
 
 import java.util.Arrays;

server/src/main/java/org/opensearch/action/support/master/TransportMasterNodeAction.java

@@ -42,7 +42,7 @@
 import org.opensearch.common.io.stream.Writeable;
 import org.elasticsearch.common.unit.TimeValue;
 import org.opensearch.discovery.MasterNotDiscoveredException;
-import org.elasticsearch.node.NodeClosedException;
+import org.opensearch.node.NodeClosedException;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.ConnectTransportException;

server/src/main/java/org/opensearch/action/support/replication/ReplicationOperation.java

@@ -40,7 +40,7 @@
 import org.elasticsearch.index.seqno.SequenceNumbers;
 import org.elasticsearch.index.shard.ReplicationGroup;
 import org.elasticsearch.index.shard.ShardId;
-import org.elasticsearch.node.NodeClosedException;
+import org.opensearch.node.NodeClosedException;
 import org.opensearch.rest.RestStatus;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.ConnectTransportException;

server/src/main/java/org/opensearch/action/support/replication/TransportReplicationAction.java

@@ -67,7 +67,7 @@
 import org.elasticsearch.index.shard.ShardNotInPrimaryModeException;
 import org.elasticsearch.indices.IndexClosedException;
 import org.elasticsearch.indices.IndicesService;
-import org.elasticsearch.node.NodeClosedException;
+import org.opensearch.node.NodeClosedException;
 import org.opensearch.tasks.Task;
 import org.opensearch.tasks.TaskId;
 import org.opensearch.threadpool.ThreadPool;

server/src/main/java/org/opensearch/action/support/single/instance/TransportInstanceSingleOperationAction.java

@@ -40,7 +40,7 @@
 import org.opensearch.common.util.concurrent.AbstractRunnable;
 import org.elasticsearch.index.IndexNotFoundException;
 import org.elasticsearch.index.shard.ShardId;
-import org.elasticsearch.node.NodeClosedException;
+import org.opensearch.node.NodeClosedException;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.threadpool.ThreadPool.Names;

server/src/main/java/org/opensearch/bootstrap/Bootstrap.java

@@ -51,9 +51,9 @@
 import org.elasticsearch.monitor.jvm.JvmInfo;
 import org.elasticsearch.monitor.os.OsProbe;
 import org.elasticsearch.monitor.process.ProcessProbe;
-import org.elasticsearch.node.InternalSettingsPreparer;
-import org.elasticsearch.node.Node;
-import org.elasticsearch.node.NodeValidationException;
+import org.opensearch.node.InternalSettingsPreparer;
+import org.opensearch.node.Node;
+import org.opensearch.node.NodeValidationException;
 
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;

server/src/main/java/org/opensearch/bootstrap/BootstrapChecks.java

@@ -34,7 +34,7 @@
 import org.elasticsearch.index.IndexModule;
 import org.elasticsearch.monitor.jvm.JvmInfo;
 import org.elasticsearch.monitor.process.ProcessProbe;
-import org.elasticsearch.node.NodeValidationException;
+import org.opensearch.node.NodeValidationException;
 
 import java.io.BufferedReader;
 import java.io.IOException;

server/src/main/java/org/opensearch/cli/EnvironmentAwareCommand.java

@@ -25,7 +25,7 @@
 import org.elasticsearch.common.SuppressForbidden;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.env.Environment;
-import org.elasticsearch.node.InternalSettingsPreparer;
+import org.opensearch.node.InternalSettingsPreparer;
 
 import java.nio.file.Path;
 import java.nio.file.Paths;

server/src/main/java/org/opensearch/cluster/node/DiscoveryNode.java

@@ -29,7 +29,7 @@
 import org.opensearch.common.transport.TransportAddress;
 import org.elasticsearch.common.xcontent.ToXContentFragment;
 import org.elasticsearch.common.xcontent.XContentBuilder;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 
 import java.io.IOException;
 import java.util.Collections;
@@ -46,7 +46,7 @@
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
-import static org.elasticsearch.node.NodeRoleSettings.NODE_ROLES_SETTING;
+import static org.opensearch.node.NodeRoleSettings.NODE_ROLES_SETTING;
 
 
 /**

server/src/main/java/org/opensearch/cluster/node/DiscoveryNodeRole.java

@@ -153,7 +153,7 @@ public final String toString() {
 
         @Override
         public Setting<Boolean> legacySetting() {
-            // copy the setting here so we can mark it private in org.elasticsearch.node.Node
+            // copy the setting here so we can mark it private in org.opensearch.node.Node
             return Setting.boolSetting("node.data", true, Property.Deprecated, Property.NodeScope);
         }
 
@@ -166,7 +166,7 @@ public Setting<Boolean> legacySetting() {
 
         @Override
         public Setting<Boolean> legacySetting() {
-            // copy the setting here so we can mark it private in org.elasticsearch.node.Node
+            // copy the setting here so we can mark it private in org.opensearch.node.Node
             return Setting.boolSetting("node.ingest", true, Property.Deprecated, Property.NodeScope);
         }
 
@@ -179,7 +179,7 @@ public Setting<Boolean> legacySetting() {
 
         @Override
         public Setting<Boolean> legacySetting() {
-            // copy the setting here so we can mark it private in org.elasticsearch.node.Node
+            // copy the setting here so we can mark it private in org.opensearch.node.Node
             return Setting.boolSetting("node.master", true, Property.Deprecated, Property.NodeScope);
         }
 
@@ -189,7 +189,7 @@ public Setting<Boolean> legacySetting() {
 
         @Override
         public Setting<Boolean> legacySetting() {
-            // copy the setting here so we can mark it private in org.elasticsearch.node.Node
+            // copy the setting here so we can mark it private in org.opensearch.node.Node
             return Setting.boolSetting(
                 "node.remote_cluster_client",
                 RemoteClusterService.ENABLE_REMOTE_CLUSTERS,

server/src/main/java/org/opensearch/cluster/routing/IndexShardRoutingTable.java

@@ -29,7 +29,7 @@
 import org.elasticsearch.common.util.set.Sets;
 import org.elasticsearch.index.Index;
 import org.elasticsearch.index.shard.ShardId;
-import org.elasticsearch.node.ResponseCollectorService;
+import org.opensearch.node.ResponseCollectorService;
 
 import java.io.IOException;
 import java.util.ArrayList;

server/src/main/java/org/opensearch/cluster/routing/OperationRouting.java

@@ -32,7 +32,7 @@
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.index.IndexNotFoundException;
 import org.elasticsearch.index.shard.ShardId;
-import org.elasticsearch.node.ResponseCollectorService;
+import org.opensearch.node.ResponseCollectorService;
 
 import java.util.ArrayList;
 import java.util.Arrays;

server/src/main/java/org/opensearch/cluster/service/ClusterService.java

@@ -36,7 +36,7 @@
 import org.elasticsearch.common.settings.Setting;
 import org.elasticsearch.common.settings.Setting.Property;
 import org.elasticsearch.common.settings.Settings;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 import org.opensearch.threadpool.ThreadPool;
 
 import java.util.Collections;

server/src/main/java/org/opensearch/common/util/concurrent/EsExecutors.java

@@ -26,7 +26,7 @@
 import org.elasticsearch.common.settings.Setting.Property;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.unit.TimeValue;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 
 import java.util.List;
 import java.util.Optional;

server/src/main/java/org/opensearch/discovery/DiscoveryModule.java

@@ -60,7 +60,7 @@
 import java.util.function.Supplier;
 import java.util.stream.Collectors;
 
-import static org.elasticsearch.node.Node.NODE_NAME_SETTING;
+import static org.opensearch.node.Node.NODE_NAME_SETTING;
 
 /**
  * A module for loading classes for node discovery.

server/src/main/java/org/opensearch/discovery/zen/UnicastZenPing.java

@@ -48,7 +48,7 @@
 import org.elasticsearch.common.util.concurrent.KeyedLock;
 import org.opensearch.discovery.SeedHostsProvider;
 import org.opensearch.discovery.SeedHostsResolver;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.ConnectTransportException;

server/src/main/java/org/opensearch/search/SearchService.java

@@ -72,7 +72,7 @@
 import org.elasticsearch.indices.IndicesService;
 import org.elasticsearch.indices.breaker.CircuitBreakerService;
 import org.elasticsearch.indices.cluster.IndicesClusterStateService.AllocatedIndices.IndexRemovalReason;
-import org.elasticsearch.node.ResponseCollectorService;
+import org.opensearch.node.ResponseCollectorService;
 import org.opensearch.script.FieldScript;
 import org.opensearch.script.ScriptService;
 import org.opensearch.search.aggregations.AggregationInitializationException;

server/src/main/java/org/opensearch/search/aggregations/support/AggregationInfo.java

@@ -22,7 +22,7 @@
 import org.opensearch.common.io.stream.StreamInput;
 import org.opensearch.common.io.stream.StreamOutput;
 import org.elasticsearch.common.xcontent.XContentBuilder;
-import org.elasticsearch.node.ReportingService;
+import org.opensearch.node.ReportingService;
 
 import java.io.IOException;
 import java.util.Collections;

server/src/main/java/org/opensearch/search/aggregations/support/AggregationUsageService.java

@@ -19,7 +19,7 @@
 
 package org.opensearch.search.aggregations.support;
 
-import org.elasticsearch.node.ReportingService;
+import org.opensearch.node.ReportingService;
 
 import java.util.HashMap;
 import java.util.Map;

server/src/main/java/org/opensearch/threadpool/AutoQueueAdjustingExecutorBuilder.java

@@ -25,7 +25,7 @@
 import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.common.util.concurrent.EsExecutors;
 import org.elasticsearch.common.util.concurrent.ThreadContext;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 
 import java.util.Arrays;
 import java.util.Collections;

server/src/main/java/org/opensearch/threadpool/FixedExecutorBuilder.java

@@ -24,7 +24,7 @@
 import org.opensearch.common.unit.SizeValue;
 import org.elasticsearch.common.util.concurrent.EsExecutors;
 import org.elasticsearch.common.util.concurrent.ThreadContext;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 
 import java.util.Arrays;
 import java.util.List;

server/src/main/java/org/opensearch/threadpool/ScalingExecutorBuilder.java

@@ -24,7 +24,7 @@
 import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.common.util.concurrent.EsExecutors;
 import org.elasticsearch.common.util.concurrent.ThreadContext;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 
 import java.util.Arrays;
 import java.util.List;

server/src/main/java/org/opensearch/transport/TcpTransport.java

@@ -55,7 +55,7 @@
 import org.elasticsearch.common.util.concurrent.CountDown;
 import org.elasticsearch.indices.breaker.CircuitBreakerService;
 import org.elasticsearch.monitor.jvm.JvmInfo;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 import org.opensearch.rest.RestStatus;
 import org.opensearch.threadpool.ThreadPool;
 

server/src/main/java/org/opensearch/transport/TransportInfo.java

@@ -27,7 +27,7 @@
 import org.opensearch.common.transport.BoundTransportAddress;
 import org.opensearch.common.transport.TransportAddress;
 import org.elasticsearch.common.xcontent.XContentBuilder;
-import org.elasticsearch.node.ReportingService;
+import org.opensearch.node.ReportingService;
 
 import java.io.IOException;
 import java.util.HashMap;

server/src/main/java/org/opensearch/transport/TransportService.java

@@ -48,8 +48,8 @@
 import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
 import org.elasticsearch.common.util.concurrent.ThreadContext;
 import org.elasticsearch.core.internal.io.IOUtils;
-import org.elasticsearch.node.NodeClosedException;
-import org.elasticsearch.node.ReportingService;
+import org.opensearch.node.NodeClosedException;
+import org.opensearch.node.ReportingService;
 import org.opensearch.tasks.Task;
 import org.opensearch.tasks.TaskManager;
 import org.opensearch.threadpool.Scheduler;

server/src/test/java/org/elasticsearch/cluster/coordination/ClusterBootstrapServiceTests.java

@@ -51,7 +51,7 @@
 import static org.elasticsearch.common.settings.Settings.builder;
 import static org.opensearch.discovery.DiscoveryModule.DISCOVERY_SEED_PROVIDERS_SETTING;
 import static org.opensearch.discovery.SettingsBasedSeedHostsProvider.DISCOVERY_SEED_HOSTS_SETTING;
-import static org.elasticsearch.node.Node.NODE_NAME_SETTING;
+import static org.opensearch.node.Node.NODE_NAME_SETTING;
 import static org.elasticsearch.test.NodeRoles.nonMasterNode;
 import static org.hamcrest.Matchers.allOf;
 import static org.hamcrest.Matchers.containsInAnyOrder;

server/src/test/java/org/elasticsearch/cluster/coordination/ClusterFormationFailureHelperTests.java

@@ -50,7 +50,7 @@
 import static org.opensearch.cluster.coordination.ClusterBootstrapService.INITIAL_MASTER_NODES_SETTING;
 import static org.elasticsearch.monitor.StatusInfo.Status.HEALTHY;
 import static org.elasticsearch.monitor.StatusInfo.Status.UNHEALTHY;
-import static org.elasticsearch.node.Node.NODE_NAME_SETTING;
+import static org.opensearch.node.Node.NODE_NAME_SETTING;
 import static org.hamcrest.Matchers.equalTo;
 import static org.hamcrest.Matchers.is;
 import static org.hamcrest.Matchers.oneOf;

server/src/test/java/org/elasticsearch/cluster/coordination/ElectionSchedulerFactoryTests.java

@@ -33,7 +33,7 @@
 import static org.opensearch.cluster.coordination.ElectionSchedulerFactory.ELECTION_INITIAL_TIMEOUT_SETTING;
 import static org.opensearch.cluster.coordination.ElectionSchedulerFactory.ELECTION_MAX_TIMEOUT_SETTING;
 import static org.opensearch.cluster.coordination.ElectionSchedulerFactory.toPositiveLongAtMost;
-import static org.elasticsearch.node.Node.NODE_NAME_SETTING;
+import static org.opensearch.node.Node.NODE_NAME_SETTING;
 import static org.hamcrest.Matchers.equalTo;
 import static org.hamcrest.Matchers.greaterThan;
 import static org.hamcrest.Matchers.greaterThanOrEqualTo;

server/src/test/java/org/elasticsearch/cluster/coordination/FollowersCheckerTests.java

@@ -69,7 +69,7 @@
 import static org.opensearch.cluster.coordination.FollowersChecker.FOLLOWER_CHECK_TIMEOUT_SETTING;
 import static org.elasticsearch.monitor.StatusInfo.Status.HEALTHY;
 import static org.elasticsearch.monitor.StatusInfo.Status.UNHEALTHY;
-import static org.elasticsearch.node.Node.NODE_NAME_SETTING;
+import static org.opensearch.node.Node.NODE_NAME_SETTING;
 import static org.opensearch.transport.TransportService.HANDSHAKE_ACTION_NAME;
 import static org.hamcrest.Matchers.contains;
 import static org.hamcrest.Matchers.containsInAnyOrder;

server/src/test/java/org/elasticsearch/cluster/coordination/JoinHelperTests.java

@@ -50,7 +50,7 @@
 
 import static org.elasticsearch.monitor.StatusInfo.Status.HEALTHY;
 import static org.elasticsearch.monitor.StatusInfo.Status.UNHEALTHY;
-import static org.elasticsearch.node.Node.NODE_NAME_SETTING;
+import static org.opensearch.node.Node.NODE_NAME_SETTING;
 import static org.hamcrest.Matchers.containsString;
 import static org.hamcrest.Matchers.equalTo;
 import static org.hamcrest.core.Is.is;

server/src/test/java/org/elasticsearch/cluster/coordination/LagDetectorTests.java

@@ -31,7 +31,7 @@
 import java.util.Set;
 
 import static org.opensearch.cluster.coordination.LagDetector.CLUSTER_FOLLOWER_LAG_TIMEOUT_SETTING;
-import static org.elasticsearch.node.Node.NODE_NAME_SETTING;
+import static org.opensearch.node.Node.NODE_NAME_SETTING;
 import static org.hamcrest.Matchers.contains;
 import static org.hamcrest.Matchers.empty;
 import static org.hamcrest.Matchers.greaterThan;

server/src/test/java/org/elasticsearch/cluster/coordination/LeaderCheckerTests.java

@@ -56,7 +56,7 @@
 import static org.opensearch.cluster.coordination.LeaderChecker.LEADER_CHECK_TIMEOUT_SETTING;
 import static org.elasticsearch.monitor.StatusInfo.Status.HEALTHY;
 import static org.elasticsearch.monitor.StatusInfo.Status.UNHEALTHY;
-import static org.elasticsearch.node.Node.NODE_NAME_SETTING;
+import static org.opensearch.node.Node.NODE_NAME_SETTING;
 import static org.opensearch.transport.TransportService.HANDSHAKE_ACTION_NAME;
 import static org.opensearch.transport.TransportService.NOOP_TRANSPORT_INTERCEPTOR;
 import static org.hamcrest.Matchers.anyOf;

server/src/test/java/org/elasticsearch/cluster/coordination/NodeJoinTests.java

@@ -41,7 +41,7 @@
 import org.opensearch.common.util.concurrent.FutureUtils;
 import org.elasticsearch.monitor.NodeHealthService;
 import org.elasticsearch.monitor.StatusInfo;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 import org.elasticsearch.test.ClusterServiceUtils;
 import org.elasticsearch.test.ESTestCase;
 import org.elasticsearch.test.transport.CapturingTransport;

server/src/test/java/org/elasticsearch/cluster/coordination/PreVoteCollectorTests.java

@@ -59,7 +59,7 @@
 import static org.opensearch.cluster.coordination.PreVoteCollector.REQUEST_PRE_VOTE_ACTION_NAME;
 import static org.elasticsearch.monitor.StatusInfo.Status.HEALTHY;
 import static org.elasticsearch.monitor.StatusInfo.Status.UNHEALTHY;
-import static org.elasticsearch.node.Node.NODE_NAME_SETTING;
+import static org.opensearch.node.Node.NODE_NAME_SETTING;
 import static org.opensearch.threadpool.ThreadPool.Names.SAME;
 import static org.hamcrest.Matchers.equalTo;
 import static org.hamcrest.Matchers.instanceOf;

server/src/test/java/org/elasticsearch/cluster/coordination/PublicationTransportHandlerTests.java

@@ -29,7 +29,7 @@
 import org.opensearch.common.io.stream.StreamOutput;
 import org.elasticsearch.common.settings.ClusterSettings;
 import org.elasticsearch.common.settings.Settings;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 import org.elasticsearch.test.ESTestCase;
 import org.elasticsearch.test.transport.CapturingTransport;
 import org.opensearch.transport.TransportService;

server/src/test/java/org/elasticsearch/cluster/service/MasterServiceTests.java

@@ -47,7 +47,7 @@
 import org.elasticsearch.common.unit.TimeValue;
 import org.opensearch.common.util.concurrent.BaseFuture;
 import org.opensearch.common.util.concurrent.ThreadContext;
-import org.elasticsearch.node.Node;
+import org.opensearch.node.Node;
 import org.elasticsearch.test.ESTestCase;
 import org.elasticsearch.test.MockLogAppender;
 import org.elasticsearch.test.junit.annotations.TestLogging;