From e176909987e786d3701741254ee01aaaba6d0b75 Mon Sep 17 00:00:00 2001 From: Lokesh Khurana Date: Tue, 25 Feb 2020 00:11:04 +0530 Subject: [PATCH 1/2] Moving classes out of test for downstreamers --- hbase-it/pom.xml | 19 +++++++++++++++++++ .../apache/hadoop/hbase/ClusterManager.java | 4 ++-- .../hadoop/hbase/DistributedHBaseCluster.java | 2 +- .../hadoop/hbase/HBaseClusterManager.java | 5 +++-- .../hbase/IntegrationTestingUtility.java | 2 ++ .../hadoop/hbase/chaos/actions/Action.java | 2 ++ .../hbase/chaos/actions/AddCPULoadAction.java | 2 ++ .../hbase/chaos/actions/AddColumnAction.java | 2 ++ .../chaos/actions/BatchRestartRsAction.java | 2 ++ .../actions/ChangeBloomFilterAction.java | 2 ++ .../actions/ChangeCompressionAction.java | 2 ++ .../chaos/actions/ChangeEncodingAction.java | 2 ++ .../actions/ChangeSplitPolicyAction.java | 2 ++ .../chaos/actions/ChangeVersionsAction.java | 2 ++ .../hbase/chaos/actions/CompactMobAction.java | 2 ++ .../CompactRandomRegionOfTableAction.java | 2 ++ .../chaos/actions/CompactTableAction.java | 2 ++ .../chaos/actions/CorruptDataFilesAction.java | 2 ++ .../actions/CorruptPacketsCommandAction.java | 2 ++ .../actions/DecreaseMaxHFileSizeAction.java | 2 ++ .../actions/DelayPacketsCommandAction.java | 2 ++ .../chaos/actions/DeleteDataFilesAction.java | 2 ++ .../actions/DumpClusterStatusAction.java | 2 ++ .../DuplicatePacketsCommandAction.java | 2 ++ .../chaos/actions/FillDiskCommandAction.java | 2 ++ .../FlushRandomRegionOfTableAction.java | 2 ++ .../hbase/chaos/actions/FlushTableAction.java | 2 ++ .../chaos/actions/ForceBalancerAction.java | 2 ++ .../GracefulRollingRestartRsAction.java | 2 ++ .../actions/LosePacketsCommandAction.java | 2 ++ ...rgeRandomAdjacentRegionsOfTableAction.java | 2 ++ .../MoveRandomRegionOfTableAction.java | 2 ++ .../actions/MoveRegionsOfTableAction.java | 2 ++ .../chaos/actions/RemoveColumnAction.java | 2 ++ .../actions/ReorderPacketsCommandAction.java | 2 ++ .../actions/RestartActionBaseAction.java | 2 ++ .../actions/RestartActiveMasterAction.java | 2 ++ .../actions/RestartActiveNameNodeAction.java | 2 ++ .../actions/RestartRandomDataNodeAction.java | 2 ++ .../chaos/actions/RestartRandomRsAction.java | 2 ++ .../RestartRandomRsExceptMetaAction.java | 2 ++ .../actions/RestartRandomZKNodeAction.java | 2 ++ .../actions/RestartRsHoldingMetaAction.java | 2 ++ .../actions/RestartRsHoldingTableAction.java | 2 ++ .../actions/RollingBatchRestartRsAction.java | 2 ++ ...RollingBatchRestartRsExceptMetaAction.java | 2 ++ .../RollingBatchSuspendResumeRsAction.java | 2 ++ .../chaos/actions/SnapshotTableAction.java | 2 ++ .../actions/SplitAllRegionOfTableAction.java | 3 ++- .../SplitRandomRegionOfTableAction.java | 2 ++ .../chaos/actions/SudoCommandAction.java | 2 ++ .../hbase/chaos/actions/TCCommandAction.java | 3 +++ .../chaos/actions/TruncateTableAction.java | 2 ++ .../UnbalanceKillAndRebalanceAction.java | 2 ++ .../chaos/actions/UnbalanceRegionsAction.java | 2 ++ .../chaos/factories/CalmMonkeyFactory.java | 3 ++- .../factories/DataIssuesMonkeyFactory.java | 2 ++ .../DistributedIssuesMonkeyFactory.java | 2 ++ .../factories/MasterKillingMonkeyFactory.java | 2 ++ .../factories/MobNoKillMonkeyFactory.java | 2 ++ .../MobSlowDeterministicMonkeyFactory.java | 2 ++ .../chaos/factories/MonkeyConstants.java | 2 ++ .../hbase/chaos/factories/MonkeyFactory.java | 2 ++ .../chaos/factories/NoKillMonkeyFactory.java | 2 ++ ...erAndDependenciesKillingMonkeyFactory.java | 2 ++ .../factories/ServerKillingMonkeyFactory.java | 2 ++ .../SlowDeterministicMonkeyFactory.java | 2 ++ .../StressAssignmentManagerMonkeyFactory.java | 2 ++ .../factories/UnbalanceMonkeyFactory.java | 2 ++ .../hbase/chaos/monkies/CalmChaosMonkey.java | 3 +++ .../hbase/chaos/monkies/ChaosMonkey.java | 2 ++ .../chaos/monkies/PolicyBasedChaosMonkey.java | 2 ++ .../policies/CompositeSequentialPolicy.java | 2 ++ .../chaos/policies/DoActionsOncePolicy.java | 2 ++ .../hbase/chaos/policies/PeriodicPolicy.java | 2 ++ .../policies/PeriodicRandomActionPolicy.java | 2 ++ .../hadoop/hbase/chaos/policies/Policy.java | 2 ++ .../policies/TwoConcurrentActionPolicy.java | 2 ++ .../hbase/chaos/util/ChaosMonkeyRunner.java | 2 ++ .../hadoop/hbase/chaos/util/Monkeys.java | 2 ++ 80 files changed, 179 insertions(+), 7 deletions(-) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/ClusterManager.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java (99%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/HBaseClusterManager.java (99%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/IntegrationTestingUtility.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/Action.java (99%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/AddCPULoadAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/BatchRestartRsAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/ChangeCompressionAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/ChangeEncodingAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/ChangeSplitPolicyAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/ChangeVersionsAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/CorruptDataFilesAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/CorruptPacketsCommandAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/DecreaseMaxHFileSizeAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/DelayPacketsCommandAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/DeleteDataFilesAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java (94%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/DuplicatePacketsCommandAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/FillDiskCommandAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/ForceBalancerAction.java (94%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/GracefulRollingRestartRsAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/LosePacketsCommandAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/MoveRandomRegionOfTableAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RemoveColumnAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/ReorderPacketsCommandAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RestartActionBaseAction.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveMasterAction.java (95%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveNameNodeAction.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomDataNodeAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsAction.java (95%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsExceptMetaAction.java (95%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomZKNodeAction.java (95%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingMetaAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java (95%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsExceptMetaAction.java (95%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchSuspendResumeRsAction.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/SnapshotTableAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/SplitAllRegionOfTableAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/SudoCommandAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/TCCommandAction.java (93%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/TruncateTableAction.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/CalmMonkeyFactory.java (93%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/DataIssuesMonkeyFactory.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/DistributedIssuesMonkeyFactory.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/MasterKillingMonkeyFactory.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/MobNoKillMonkeyFactory.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/MobSlowDeterministicMonkeyFactory.java (99%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/MonkeyFactory.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/NoKillMonkeyFactory.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/ServerAndDependenciesKillingMonkeyFactory.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/ServerKillingMonkeyFactory.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/SlowDeterministicMonkeyFactory.java (99%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/StressAssignmentManagerMonkeyFactory.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/factories/UnbalanceMonkeyFactory.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/monkies/CalmChaosMonkey.java (94%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/monkies/ChaosMonkey.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/policies/CompositeSequentialPolicy.java (95%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/policies/DoActionsOncePolicy.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/policies/PeriodicRandomActionPolicy.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/policies/Policy.java (96%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/policies/TwoConcurrentActionPolicy.java (97%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java (98%) rename hbase-it/src/{test => main}/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java (97%) diff --git a/hbase-it/pom.xml b/hbase-it/pom.xml index 0fe578a99f..48241eb779 100644 --- a/hbase-it/pom.xml +++ b/hbase-it/pom.xml @@ -154,10 +154,29 @@ test-jar test + + org.apache.hbase + hbase-server + test-jar + compile + + + org.apache.hbase + hbase-zookeeper + test-jar + compile + org.apache.hbase hbase-common jar + compile + + + org.apache.hbase + hbase-common + test-jar + compile org.apache.hbase diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/ClusterManager.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/ClusterManager.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/ClusterManager.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/ClusterManager.java index 6356345aa1..d6917c1ebd 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/ClusterManager.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/ClusterManager.java @@ -29,8 +29,8 @@ import org.apache.yetus.audience.InterfaceAudience; * for starting / stopping / killing Hadoop/HBase daemons. Concrete implementations provide actual * functionality for carrying out deployment-specific tasks. */ -@InterfaceAudience.Private -interface ClusterManager extends Configurable { +@InterfaceAudience.Public +public interface ClusterManager extends Configurable { /** * Type of the service daemon */ diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java similarity index 99% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java index 796bc1f27e..865c5e2191 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/DistributedHBaseCluster.java @@ -41,7 +41,7 @@ import org.apache.yetus.audience.InterfaceAudience; * Manages the interactions with an already deployed distributed cluster (as opposed to * a pseudo-distributed, or mini/local cluster). This is used by integration and system tests. */ -@InterfaceAudience.Private +@InterfaceAudience.Public public class DistributedHBaseCluster extends HBaseCluster { private Admin admin; private final Connection connection; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/HBaseClusterManager.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/HBaseClusterManager.java similarity index 99% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/HBaseClusterManager.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/HBaseClusterManager.java index 2f75c731bf..ed09d17af6 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/HBaseClusterManager.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/HBaseClusterManager.java @@ -43,8 +43,9 @@ import org.slf4j.LoggerFactory; * servers on the remote machines (for example, the test user could be the same user as the * user the daemon is running as) */ -@InterfaceAudience.Private -public class HBaseClusterManager extends Configured implements ClusterManager { +@InterfaceAudience.Public +public class HBaseClusterManager extends Configured implements + org.apache.hadoop.hbase.ClusterManager { private static final String SIGKILL = "SIGKILL"; private static final String SIGSTOP = "SIGSTOP"; private static final String SIGCONT = "SIGCONT"; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestingUtility.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/IntegrationTestingUtility.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestingUtility.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/IntegrationTestingUtility.java index a9e555eaec..4862e72a96 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestingUtility.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/IntegrationTestingUtility.java @@ -21,6 +21,7 @@ package org.apache.hadoop.hbase; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.util.ReflectionUtils; +import org.apache.yetus.audience.InterfaceAudience; /** * Facility for integration/system tests. This extends {@link HBaseTestingUtility} @@ -39,6 +40,7 @@ import org.apache.hadoop.util.ReflectionUtils; * via {@link #initializeCluster(int)}. Individual tests should not directly call * {@link #setUseDistributedCluster(Configuration)}. */ +@InterfaceAudience.Public public class IntegrationTestingUtility extends HBaseTestingUtility { public IntegrationTestingUtility() { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/Action.java similarity index 99% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/Action.java index 98ad2dc85e..d6e693ae0a 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/Action.java @@ -46,12 +46,14 @@ import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; import org.apache.hadoop.hbase.client.TableDescriptor; import org.apache.hadoop.hbase.client.TableDescriptorBuilder; import org.apache.hadoop.hbase.util.Bytes; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * A (possibly mischievous) action that the ChaosMonkey can perform. */ +@InterfaceAudience.Public public class Action { public static final String KILL_MASTER_TIMEOUT_KEY = diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddCPULoadAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/AddCPULoadAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddCPULoadAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/AddCPULoadAction.java index 9d6437e431..3e89b51df0 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddCPULoadAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/AddCPULoadAction.java @@ -22,12 +22,14 @@ import java.io.IOException; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that adds high cpu load to a random regionserver for a given duration */ +@InterfaceAudience.Public public class AddCPULoadAction extends SudoCommandAction { protected static final Logger LOG = LoggerFactory.getLogger(AddCPULoadAction.class); private static final String CPU_LOAD_COMMAND = diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java index a01222aee9..6e3d65cbe3 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/AddColumnAction.java @@ -27,12 +27,14 @@ import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; import org.apache.hadoop.hbase.client.TableDescriptor; import org.apache.hadoop.hbase.client.TableDescriptorBuilder; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action the adds a column family to a table. */ +@InterfaceAudience.Public public class AddColumnAction extends Action { private final TableName tableName; private Admin admin; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/BatchRestartRsAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/BatchRestartRsAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/BatchRestartRsAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/BatchRestartRsAction.java index 2026a913a5..c54cd3a847 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/BatchRestartRsAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/BatchRestartRsAction.java @@ -24,12 +24,14 @@ import java.util.Set; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Restarts a ratio of the running regionservers at the same time */ +@InterfaceAudience.Public public class BatchRestartRsAction extends RestartActionBaseAction { float ratio; //ratio of regionservers to restart private static final Logger LOG = diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java index e76675aa4b..cb56b2fac2 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java @@ -23,6 +23,7 @@ import java.util.Random; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.regionserver.BloomType; import org.apache.hadoop.hbase.util.BloomFilterUtil; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -30,6 +31,7 @@ import org.slf4j.LoggerFactory; * Action that tries to adjust the bloom filter setting on all the columns of a * table */ +@InterfaceAudience.Public public class ChangeBloomFilterAction extends Action { private final long sleepTime; private final TableName tableName; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeCompressionAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeCompressionAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeCompressionAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeCompressionAction.java index 533028428f..3c1d4d60c3 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeCompressionAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeCompressionAction.java @@ -24,12 +24,14 @@ import java.util.Random; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.io.compress.Compression.Algorithm; import org.apache.hadoop.io.compress.Compressor; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that changes the compression algorithm on a column family from a list of tables. */ +@InterfaceAudience.Public public class ChangeCompressionAction extends Action { private final TableName tableName; private final Random random; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeEncodingAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeEncodingAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeEncodingAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeEncodingAction.java index 55a308ce38..4d9cfb4db8 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeEncodingAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeEncodingAction.java @@ -23,12 +23,14 @@ import java.util.Random; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that changes the encoding on a column family from a list of tables. */ +@InterfaceAudience.Public public class ChangeEncodingAction extends Action { private final TableName tableName; private final Random random; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeSplitPolicyAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeSplitPolicyAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeSplitPolicyAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeSplitPolicyAction.java index 72ff50fc09..604f6ba9f7 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeSplitPolicyAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeSplitPolicyAction.java @@ -27,9 +27,11 @@ import org.apache.hadoop.hbase.client.TableDescriptorBuilder; import org.apache.hadoop.hbase.regionserver.ConstantSizeRegionSplitPolicy; import org.apache.hadoop.hbase.regionserver.DisabledRegionSplitPolicy; import org.apache.hadoop.hbase.regionserver.IncreasingToUpperBoundRegionSplitPolicy; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +@InterfaceAudience.Public public class ChangeSplitPolicyAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(ChangeSplitPolicyAction.class); private final TableName tableName; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeVersionsAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeVersionsAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeVersionsAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeVersionsAction.java index 18dba94a30..25617f452d 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeVersionsAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ChangeVersionsAction.java @@ -22,6 +22,7 @@ import java.io.IOException; import java.util.Random; import org.apache.hadoop.hbase.TableName; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -30,6 +31,7 @@ import org.slf4j.LoggerFactory; * * Always keeps at least 1 as the number of versions. */ +@InterfaceAudience.Public public class ChangeVersionsAction extends Action { private final TableName tableName; private static final Logger LOG = LoggerFactory.getLogger(ChangeVersionsAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java index 6ac71d5739..b7f1604174 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CompactMobAction.java @@ -23,12 +23,14 @@ import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.CompactType; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that queues a table compaction. */ +@InterfaceAudience.Public public class CompactMobAction extends Action { private final TableName tableName; private final int majorRatio; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java index 9a46147014..cba460b18f 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CompactRandomRegionOfTableAction.java @@ -26,12 +26,14 @@ import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.RegionInfo; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Region that queues a compaction of a random region from the table. */ +@InterfaceAudience.Public public class CompactRandomRegionOfTableAction extends Action { private final int majorRatio; private final long sleepTime; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java index c05d43b89f..53b9d98890 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CompactTableAction.java @@ -22,12 +22,14 @@ import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that queues a table compaction. */ +@InterfaceAudience.Public public class CompactTableAction extends Action { private final TableName tableName; private final int majorRatio; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CorruptDataFilesAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CorruptDataFilesAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CorruptDataFilesAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CorruptDataFilesAction.java index 83e8fe08a4..c53a720d52 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CorruptDataFilesAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CorruptDataFilesAction.java @@ -26,12 +26,14 @@ import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.RemoteIterator; import org.apache.hadoop.hbase.io.hfile.HFile; import org.apache.hadoop.hbase.util.CommonFSUtils; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action corrupts HFiles with a certain chance. */ +@InterfaceAudience.Public public class CorruptDataFilesAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(CorruptDataFilesAction.class); private float chance; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CorruptPacketsCommandAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CorruptPacketsCommandAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CorruptPacketsCommandAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CorruptPacketsCommandAction.java index 965bcbb6d4..d2927d76a1 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/CorruptPacketsCommandAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/CorruptPacketsCommandAction.java @@ -22,6 +22,7 @@ import java.io.IOException; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -29,6 +30,7 @@ import org.slf4j.LoggerFactory; * * Corrupt network packets on a random regionserver. */ +@InterfaceAudience.Public public class CorruptPacketsCommandAction extends TCCommandAction { private static final Logger LOG = LoggerFactory.getLogger(CorruptPacketsCommandAction.class); private float ratio; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DecreaseMaxHFileSizeAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DecreaseMaxHFileSizeAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DecreaseMaxHFileSizeAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DecreaseMaxHFileSizeAction.java index 4610ef0de7..de762d1e45 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DecreaseMaxHFileSizeAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DecreaseMaxHFileSizeAction.java @@ -26,7 +26,9 @@ import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.TableDescriptor; import org.apache.hadoop.hbase.client.TableDescriptorBuilder; +import org.apache.yetus.audience.InterfaceAudience; +@InterfaceAudience.Public public class DecreaseMaxHFileSizeAction extends Action { private static final long minFileSize = 1 * 1024 * 1024 * 1024L; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DelayPacketsCommandAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DelayPacketsCommandAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DelayPacketsCommandAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DelayPacketsCommandAction.java index 38578d8690..d4e5b5a742 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DelayPacketsCommandAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DelayPacketsCommandAction.java @@ -22,12 +22,14 @@ import java.io.IOException; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action adds latency to communication on a random regionserver. */ +@InterfaceAudience.Public public class DelayPacketsCommandAction extends TCCommandAction { private static final Logger LOG = LoggerFactory.getLogger(DelayPacketsCommandAction.class); private long delay; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DeleteDataFilesAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DeleteDataFilesAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DeleteDataFilesAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DeleteDataFilesAction.java index 4919adce49..b71788d806 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DeleteDataFilesAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DeleteDataFilesAction.java @@ -25,12 +25,14 @@ import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.RemoteIterator; import org.apache.hadoop.hbase.io.hfile.HFile; import org.apache.hadoop.hbase.util.CommonFSUtils; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action deletes HFiles with a certain chance. */ +@InterfaceAudience.Public public class DeleteDataFilesAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(DeleteDataFilesAction.class); private float chance; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java similarity index 94% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java index 3c70af0349..4cd0e53711 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DumpClusterStatusAction.java @@ -20,12 +20,14 @@ package org.apache.hadoop.hbase.chaos.actions; import java.io.IOException; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action to dump the cluster status. */ +@InterfaceAudience.Public public class DumpClusterStatusAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(DumpClusterStatusAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DuplicatePacketsCommandAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DuplicatePacketsCommandAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DuplicatePacketsCommandAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DuplicatePacketsCommandAction.java index 7ed74ec4cd..a2ad9bebf3 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DuplicatePacketsCommandAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/DuplicatePacketsCommandAction.java @@ -22,6 +22,7 @@ import java.io.IOException; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -29,6 +30,7 @@ import org.slf4j.LoggerFactory; * * Duplicate network packets on a random regionserver. */ +@InterfaceAudience.Public public class DuplicatePacketsCommandAction extends TCCommandAction { private static final Logger LOG = LoggerFactory.getLogger(DuplicatePacketsCommandAction.class); private float ratio; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FillDiskCommandAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/FillDiskCommandAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FillDiskCommandAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/FillDiskCommandAction.java index f5ca1d7f19..8179d70ae8 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FillDiskCommandAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/FillDiskCommandAction.java @@ -22,6 +22,7 @@ import java.io.IOException; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -29,6 +30,7 @@ import org.slf4j.LoggerFactory; * * Fill the disk on a random regionserver. */ +@InterfaceAudience.Public public class FillDiskCommandAction extends SudoCommandAction { private static final Logger LOG = LoggerFactory.getLogger(FillDiskCommandAction.class); private long size; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java index 083423c4ca..e5f18cbc50 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/FlushRandomRegionOfTableAction.java @@ -24,12 +24,14 @@ import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.RegionInfo; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to flush a random region of a table. */ +@InterfaceAudience.Public public class FlushRandomRegionOfTableAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(FlushRandomRegionOfTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java index 93f7347ac9..1778f94545 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/FlushTableAction.java @@ -21,12 +21,14 @@ package org.apache.hadoop.hbase.chaos.actions; import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to flush a table. */ +@InterfaceAudience.Public public class FlushTableAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(FlushTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ForceBalancerAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ForceBalancerAction.java similarity index 94% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ForceBalancerAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ForceBalancerAction.java index d75475432a..bcb16296c9 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ForceBalancerAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ForceBalancerAction.java @@ -18,12 +18,14 @@ package org.apache.hadoop.hbase.chaos.actions; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to force a balancer run. */ +@InterfaceAudience.Public public class ForceBalancerAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(ForceBalancerAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/GracefulRollingRestartRsAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/GracefulRollingRestartRsAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/GracefulRollingRestartRsAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/GracefulRollingRestartRsAction.java index 82005bbbd4..5bdc3199dd 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/GracefulRollingRestartRsAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/GracefulRollingRestartRsAction.java @@ -25,6 +25,7 @@ import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.util.RegionMover; import org.apache.hadoop.util.Shell; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -32,6 +33,7 @@ import org.slf4j.LoggerFactory; * Gracefully restarts every regionserver in a rolling fashion. At each step, it unloads, * restarts the loads every rs server sleeping randomly (0-sleepTime) in between servers. */ +@InterfaceAudience.Public public class GracefulRollingRestartRsAction extends RestartActionBaseAction { private static final Logger LOG = LoggerFactory.getLogger(GracefulRollingRestartRsAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/LosePacketsCommandAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/LosePacketsCommandAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/LosePacketsCommandAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/LosePacketsCommandAction.java index 8b09daf4cf..b5c9a9cd4c 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/LosePacketsCommandAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/LosePacketsCommandAction.java @@ -22,6 +22,7 @@ import java.io.IOException; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -29,6 +30,7 @@ import org.slf4j.LoggerFactory; * * Lose network packets on a random regionserver. */ +@InterfaceAudience.Public public class LosePacketsCommandAction extends TCCommandAction { private static final Logger LOG = LoggerFactory.getLogger(LosePacketsCommandAction.class); private float ratio; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java index 085413d6e6..bbdfe743b9 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/MergeRandomAdjacentRegionsOfTableAction.java @@ -24,12 +24,14 @@ import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.RegionInfo; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action to merge regions of a table. */ +@InterfaceAudience.Public public class MergeRandomAdjacentRegionsOfTableAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(MergeRandomAdjacentRegionsOfTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRandomRegionOfTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/MoveRandomRegionOfTableAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRandomRegionOfTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/MoveRandomRegionOfTableAction.java index cdd2f20aed..8ebcd3caf8 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRandomRegionOfTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/MoveRandomRegionOfTableAction.java @@ -25,12 +25,14 @@ import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.RegionInfo; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to move a random region of a table. */ +@InterfaceAudience.Public public class MoveRandomRegionOfTableAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(MoveRandomRegionOfTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java index 1c1f07b3df..27869de282 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/MoveRegionsOfTableAction.java @@ -29,12 +29,14 @@ import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.chaos.factories.MonkeyConstants; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.RegionInfo; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to move every region of a table. */ +@InterfaceAudience.Public public class MoveRegionsOfTableAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(MoveRegionsOfTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RemoveColumnAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RemoveColumnAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RemoveColumnAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RemoveColumnAction.java index 37e540104d..56f8706262 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RemoveColumnAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RemoveColumnAction.java @@ -28,12 +28,14 @@ import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; import org.apache.hadoop.hbase.client.TableDescriptor; import org.apache.hadoop.hbase.client.TableDescriptorBuilder; import org.apache.hadoop.hbase.util.Bytes; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that removes a column family. */ +@InterfaceAudience.Public public class RemoveColumnAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(RemoveColumnAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ReorderPacketsCommandAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ReorderPacketsCommandAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ReorderPacketsCommandAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ReorderPacketsCommandAction.java index 1bb7969bb7..9316c58b57 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ReorderPacketsCommandAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/ReorderPacketsCommandAction.java @@ -22,6 +22,7 @@ import java.io.IOException; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -29,6 +30,7 @@ import org.slf4j.LoggerFactory; * * Reorder network packets on a random regionserver. */ +@InterfaceAudience.Public public class ReorderPacketsCommandAction extends TCCommandAction { private static final Logger LOG = LoggerFactory.getLogger(ReorderPacketsCommandAction.class); private float ratio; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActionBaseAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartActionBaseAction.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActionBaseAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartActionBaseAction.java index c53de90822..b86332dc3b 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActionBaseAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartActionBaseAction.java @@ -22,12 +22,14 @@ import java.io.IOException; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.util.Threads; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Base class for restarting HBaseServer's */ +@InterfaceAudience.Public public class RestartActionBaseAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(RestartActionBaseAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveMasterAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveMasterAction.java similarity index 95% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveMasterAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveMasterAction.java index ddd719a6e6..be1da5ce18 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveMasterAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveMasterAction.java @@ -19,12 +19,14 @@ package org.apache.hadoop.hbase.chaos.actions; import org.apache.hadoop.hbase.ServerName; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to restart the active master. */ +@InterfaceAudience.Public public class RestartActiveMasterAction extends RestartActionBaseAction { private static final Logger LOG = LoggerFactory.getLogger(RestartActionBaseAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveNameNodeAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveNameNodeAction.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveNameNodeAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveNameNodeAction.java index 2fc64e68a2..5ceaa619a4 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveNameNodeAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveNameNodeAction.java @@ -30,12 +30,14 @@ import org.apache.hadoop.hbase.zookeeper.ZNodePaths; import org.apache.hadoop.hdfs.DFSUtil; import org.apache.hadoop.hdfs.HAUtil; import org.apache.hadoop.hdfs.server.namenode.ha.proto.HAZKInfoProtos.ActiveNodeInfo; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to restart the active namenode. */ +@InterfaceAudience.Public public class RestartActiveNameNodeAction extends RestartActionBaseAction { private static final Logger LOG = LoggerFactory.getLogger(RestartActiveNameNodeAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomDataNodeAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomDataNodeAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomDataNodeAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomDataNodeAction.java index 5824a42fca..ae7f6135da 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomDataNodeAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomDataNodeAction.java @@ -29,12 +29,14 @@ import org.apache.hadoop.hdfs.DFSClient; import org.apache.hadoop.hdfs.DistributedFileSystem; import org.apache.hadoop.hdfs.protocol.DatanodeInfo; import org.apache.hadoop.hdfs.protocol.HdfsConstants; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that restarts a random datanode. */ +@InterfaceAudience.Public public class RestartRandomDataNodeAction extends RestartActionBaseAction { private static final Logger LOG = LoggerFactory.getLogger(RestartRandomDataNodeAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsAction.java similarity index 95% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsAction.java index 48458b68dc..eca3a003ad 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsAction.java @@ -20,12 +20,14 @@ package org.apache.hadoop.hbase.chaos.actions; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that restarts a random HRegionServer */ +@InterfaceAudience.Public public class RestartRandomRsAction extends RestartActionBaseAction { private static final Logger LOG = LoggerFactory.getLogger(RestartRandomRsAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsExceptMetaAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsExceptMetaAction.java similarity index 95% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsExceptMetaAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsExceptMetaAction.java index b78144a1ca..538cb63db3 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsExceptMetaAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomRsExceptMetaAction.java @@ -20,7 +20,9 @@ package org.apache.hadoop.hbase.chaos.actions; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; +@InterfaceAudience.Public public class RestartRandomRsExceptMetaAction extends RestartRandomRsAction { public RestartRandomRsExceptMetaAction(long sleepTime) { super(sleepTime); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomZKNodeAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomZKNodeAction.java similarity index 95% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomZKNodeAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomZKNodeAction.java index 3ed7a0d923..aa92361468 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomZKNodeAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRandomZKNodeAction.java @@ -21,12 +21,14 @@ package org.apache.hadoop.hbase.chaos.actions; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.zookeeper.ZKServerTool; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that restarts a random zookeeper node. */ +@InterfaceAudience.Public public class RestartRandomZKNodeAction extends RestartActionBaseAction { private static final Logger LOG = LoggerFactory.getLogger(RestartRandomZKNodeAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingMetaAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingMetaAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingMetaAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingMetaAction.java index aeecf0a891..0f167ac782 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingMetaAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingMetaAction.java @@ -20,12 +20,14 @@ package org.apache.hadoop.hbase.chaos.actions; import org.apache.hadoop.hbase.ClusterMetrics; import org.apache.hadoop.hbase.ServerName; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to restart the HRegionServer holding Meta. */ +@InterfaceAudience.Public public class RestartRsHoldingMetaAction extends RestartActionBaseAction { private static final Logger LOG = LoggerFactory.getLogger(RestartRsHoldingMetaAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java similarity index 95% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java index a63c672db3..c06902464d 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RestartRsHoldingTableAction.java @@ -23,12 +23,14 @@ import java.util.List; import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.HRegionLocation; import org.apache.hadoop.hbase.client.RegionLocator; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that restarts an HRegionServer holding one of the regions of the table. */ +@InterfaceAudience.Public public class RestartRsHoldingTableAction extends RestartActionBaseAction { private static final Logger LOG = LoggerFactory.getLogger(RestartRsHoldingTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java index 53f9520834..fa7f5171f2 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsAction.java @@ -27,6 +27,7 @@ import java.util.Queue; import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -36,6 +37,7 @@ import org.slf4j.LoggerFactory; * The parameter maxDeadServers limits the maximum number of servers that * can be down at the same time during rolling restarts. */ +@InterfaceAudience.Public public class RollingBatchRestartRsAction extends BatchRestartRsAction { private static final Logger LOG = LoggerFactory.getLogger(RollingBatchRestartRsAction.class); protected int maxDeadServers; // number of maximum dead servers at any given time. Defaults to 5 diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsExceptMetaAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsExceptMetaAction.java similarity index 95% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsExceptMetaAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsExceptMetaAction.java index d0d0fe561d..a575d1e372 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsExceptMetaAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchRestartRsExceptMetaAction.java @@ -21,11 +21,13 @@ package org.apache.hadoop.hbase.chaos.actions; import java.util.List; import org.apache.hadoop.hbase.ServerName; +import org.apache.yetus.audience.InterfaceAudience; /** * Same as in {@link RollingBatchRestartRsAction} except that this action * does not restart the region server holding the META table. */ +@InterfaceAudience.Public public class RollingBatchRestartRsExceptMetaAction extends RollingBatchRestartRsAction { public RollingBatchRestartRsExceptMetaAction(long sleepTime, float ratio, int maxDeadServers) { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchSuspendResumeRsAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchSuspendResumeRsAction.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchSuspendResumeRsAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchSuspendResumeRsAction.java index d4ad3e40b5..2720578dcc 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchSuspendResumeRsAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/RollingBatchSuspendResumeRsAction.java @@ -28,6 +28,7 @@ import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.util.Threads; import org.apache.hadoop.util.Shell; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -37,6 +38,7 @@ import org.slf4j.LoggerFactory; * maxSuspendedServers limits the maximum number of servers that can be down at the same time * during rolling restarts. */ +@InterfaceAudience.Public public class RollingBatchSuspendResumeRsAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(RollingBatchSuspendResumeRsAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SnapshotTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SnapshotTableAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SnapshotTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SnapshotTableAction.java index 6ee9b57b8a..1ebf42037b 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SnapshotTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SnapshotTableAction.java @@ -21,12 +21,14 @@ package org.apache.hadoop.hbase.chaos.actions; import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to take a snapshot of a table. */ +@InterfaceAudience.Public public class SnapshotTableAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(SnapshotTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitAllRegionOfTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SplitAllRegionOfTableAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitAllRegionOfTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SplitAllRegionOfTableAction.java index 10d5440516..aa9e8f0ed5 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitAllRegionOfTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SplitAllRegionOfTableAction.java @@ -23,10 +23,11 @@ import java.util.concurrent.ThreadLocalRandom; import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; - +@InterfaceAudience.Public public class SplitAllRegionOfTableAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(SplitAllRegionOfTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java index b4873753bb..d2f7090dc4 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SplitRandomRegionOfTableAction.java @@ -25,12 +25,14 @@ import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.RegionInfo; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to split a random region of a table. */ +@InterfaceAudience.Public public class SplitRandomRegionOfTableAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(SplitRandomRegionOfTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SudoCommandAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SudoCommandAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SudoCommandAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SudoCommandAction.java index 6092a5dbbc..a8cbd87a3b 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/SudoCommandAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/SudoCommandAction.java @@ -23,12 +23,14 @@ import java.io.IOException; import org.apache.hadoop.hbase.DistributedHBaseCluster; import org.apache.hadoop.hbase.HBaseCluster; import org.apache.hadoop.hbase.HBaseClusterManager; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Base class for performing Actions based on linux commands requiring sudo privileges */ +@InterfaceAudience.Public abstract public class SudoCommandAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(SudoCommandAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/TCCommandAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/TCCommandAction.java similarity index 93% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/TCCommandAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/TCCommandAction.java index 9444f876f7..4754cf534a 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/TCCommandAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/TCCommandAction.java @@ -18,9 +18,12 @@ package org.apache.hadoop.hbase.chaos.actions; +import org.apache.yetus.audience.InterfaceAudience; + /** * Base class for tc command actions */ +@InterfaceAudience.Public abstract public class TCCommandAction extends SudoCommandAction { protected static final String ADD = "add"; protected static final String DELETE = "del"; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/TruncateTableAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/TruncateTableAction.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/TruncateTableAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/TruncateTableAction.java index b79dafa14e..f8634f63c3 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/TruncateTableAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/TruncateTableAction.java @@ -23,12 +23,14 @@ import java.util.Random; import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to truncate of a table. */ +@InterfaceAudience.Public public class TruncateTableAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(TruncateTableAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java index 5e5504af10..021e94c05c 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceKillAndRebalanceAction.java @@ -27,11 +27,13 @@ import java.util.Set; import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.ClusterMetrics; import org.apache.hadoop.hbase.ServerName; +import org.apache.yetus.audience.InterfaceAudience; import org.junit.Assert; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** This action is too specific to put in ChaosMonkey; put it here */ +@InterfaceAudience.Public public class UnbalanceKillAndRebalanceAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(UnbalanceKillAndRebalanceAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java index 3f2a3a1b51..65b2417901 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/actions/UnbalanceRegionsAction.java @@ -25,12 +25,14 @@ import java.util.List; import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.ClusterMetrics; import org.apache.hadoop.hbase.ServerName; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Action that tries to unbalance the regions of a cluster. */ +@InterfaceAudience.Public public class UnbalanceRegionsAction extends Action { private static final Logger LOG = LoggerFactory.getLogger(UnbalanceRegionsAction.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/CalmMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/CalmMonkeyFactory.java similarity index 93% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/CalmMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/CalmMonkeyFactory.java index e109585722..35c08bdb0e 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/CalmMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/CalmMonkeyFactory.java @@ -20,11 +20,12 @@ package org.apache.hadoop.hbase.chaos.factories; import org.apache.hadoop.hbase.chaos.monkies.CalmChaosMonkey; import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; - +import org.apache.yetus.audience.InterfaceAudience; /** * Factory to create a calm ChaosMonkey. */ +@InterfaceAudience.Private public class CalmMonkeyFactory extends MonkeyFactory { @Override public ChaosMonkey build() { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/DataIssuesMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/DataIssuesMonkeyFactory.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/DataIssuesMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/DataIssuesMonkeyFactory.java index a06a9779e4..0b575945d5 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/DataIssuesMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/DataIssuesMonkeyFactory.java @@ -25,12 +25,14 @@ import org.apache.hadoop.hbase.chaos.actions.DumpClusterStatusAction; import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; /** * A chaos monkey to delete and corrupt regionserver data, requires a user with * passwordless ssh access to the cluster and sudo privileges. * Highly destructive */ +@InterfaceAudience.Private public class DataIssuesMonkeyFactory extends MonkeyFactory { private long action1Period; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/DistributedIssuesMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/DistributedIssuesMonkeyFactory.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/DistributedIssuesMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/DistributedIssuesMonkeyFactory.java index 3091fa5557..03dc0e6c9e 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/DistributedIssuesMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/DistributedIssuesMonkeyFactory.java @@ -30,11 +30,13 @@ import org.apache.hadoop.hbase.chaos.actions.ReorderPacketsCommandAction; import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; /** * A chaos monkey to create distributed cluster related issues, requires a user with * passwordless ssh access to the cluster and sudo privileges. */ +@InterfaceAudience.Private public class DistributedIssuesMonkeyFactory extends MonkeyFactory { private long action1Period; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MasterKillingMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MasterKillingMonkeyFactory.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MasterKillingMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MasterKillingMonkeyFactory.java index 52dec3beb3..dc39b83c98 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MasterKillingMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MasterKillingMonkeyFactory.java @@ -24,11 +24,13 @@ import org.apache.hadoop.hbase.chaos.actions.RestartActiveMasterAction; import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; /** * A chaos monkey to kill the active master periodically. Can be run in single master * or multi master setup. */ +@InterfaceAudience.Private public class MasterKillingMonkeyFactory extends MonkeyFactory { private long action1Period; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MobNoKillMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MobNoKillMonkeyFactory.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MobNoKillMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MobNoKillMonkeyFactory.java index 639937820f..42df04d257 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MobNoKillMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MobNoKillMonkeyFactory.java @@ -39,10 +39,12 @@ import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; import org.apache.hadoop.hbase.chaos.policies.TwoConcurrentActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; /** * This is a copy of NoKillMonkeyFactory that also does mob compactions. */ +@InterfaceAudience.Private public class MobNoKillMonkeyFactory extends MonkeyFactory { @Override public ChaosMonkey build() { Action[] actions1 = new Action[] { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MobSlowDeterministicMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MobSlowDeterministicMonkeyFactory.java similarity index 99% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MobSlowDeterministicMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MobSlowDeterministicMonkeyFactory.java index c59bfd6660..a7b7555a51 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MobSlowDeterministicMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MobSlowDeterministicMonkeyFactory.java @@ -45,10 +45,12 @@ import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.CompositeSequentialPolicy; import org.apache.hadoop.hbase.chaos.policies.DoActionsOncePolicy; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; /** * This is a copy of SlowDeterministicMonkeyFactory that also does mob compactions. */ +@InterfaceAudience.Private public class MobSlowDeterministicMonkeyFactory extends MonkeyFactory { private long action1Period; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java index 7fbdd1ff83..aa7864748e 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java @@ -17,10 +17,12 @@ */ package org.apache.hadoop.hbase.chaos.factories; +import org.apache.yetus.audience.InterfaceAudience; import java.util.Arrays; import java.util.HashSet; import java.util.Set; +@InterfaceAudience.Private public interface MonkeyConstants { String PERIODIC_ACTION1_PERIOD = "sdm.action1.period"; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyFactory.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyFactory.java index 73f6968244..1a6e5b234f 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/MonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyFactory.java @@ -28,12 +28,14 @@ import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; import org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap; import org.apache.hadoop.hbase.util.ReflectionUtils; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Base class of the factory that will create a ChaosMonkey. */ +@InterfaceAudience.Public public abstract class MonkeyFactory { private static final Logger LOG = LoggerFactory.getLogger(MonkeyFactory.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/NoKillMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/NoKillMonkeyFactory.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/NoKillMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/NoKillMonkeyFactory.java index def9df0bfa..5e77347e96 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/NoKillMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/NoKillMonkeyFactory.java @@ -39,11 +39,13 @@ import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; import org.apache.hadoop.hbase.chaos.policies.TwoConcurrentActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; /** * Monkey factory to create a ChaosMonkey that will not need access to ssh. It will not * kill any services and it will not perform any restarts. */ +@InterfaceAudience.Private public class NoKillMonkeyFactory extends MonkeyFactory { @Override public ChaosMonkey build() { Action[] actions1 = new Action[] { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/ServerAndDependenciesKillingMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/ServerAndDependenciesKillingMonkeyFactory.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/ServerAndDependenciesKillingMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/ServerAndDependenciesKillingMonkeyFactory.java index 5cb2d7f7b8..db4ff7f969 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/ServerAndDependenciesKillingMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/ServerAndDependenciesKillingMonkeyFactory.java @@ -33,11 +33,13 @@ import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.CompositeSequentialPolicy; import org.apache.hadoop.hbase.chaos.policies.DoActionsOncePolicy; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; /** * Creates ChaosMonkeys for doing server restart actions, but not * flush / compact / snapshot kind of actions. */ +@InterfaceAudience.Private public class ServerAndDependenciesKillingMonkeyFactory extends MonkeyFactory { private long gracefulRollingRestartTSSLeepTime; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/ServerKillingMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/ServerKillingMonkeyFactory.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/ServerKillingMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/ServerKillingMonkeyFactory.java index 3f2edcc9f8..ba3ab9f3b7 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/ServerKillingMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/ServerKillingMonkeyFactory.java @@ -31,11 +31,13 @@ import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.CompositeSequentialPolicy; import org.apache.hadoop.hbase.chaos.policies.DoActionsOncePolicy; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; /** * Creates ChaosMonkeys for doing server restart actions, but not * flush / compact / snapshot kind of actions. */ +@InterfaceAudience.Private public class ServerKillingMonkeyFactory extends MonkeyFactory { private long gracefulRollingRestartTSSLeepTime; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/SlowDeterministicMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/SlowDeterministicMonkeyFactory.java similarity index 99% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/SlowDeterministicMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/SlowDeterministicMonkeyFactory.java index deaf25640c..f162d2b2d9 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/SlowDeterministicMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/SlowDeterministicMonkeyFactory.java @@ -49,7 +49,9 @@ import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.CompositeSequentialPolicy; import org.apache.hadoop.hbase.chaos.policies.DoActionsOncePolicy; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; +@InterfaceAudience.Private public class SlowDeterministicMonkeyFactory extends MonkeyFactory { private long action1Period; private long action2Period; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/StressAssignmentManagerMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/StressAssignmentManagerMonkeyFactory.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/StressAssignmentManagerMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/StressAssignmentManagerMonkeyFactory.java index b25bef7a33..dbd737c529 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/StressAssignmentManagerMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/StressAssignmentManagerMonkeyFactory.java @@ -43,7 +43,9 @@ import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.CompositeSequentialPolicy; import org.apache.hadoop.hbase.chaos.policies.DoActionsOncePolicy; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; +import org.apache.yetus.audience.InterfaceAudience; +@InterfaceAudience.Private public class StressAssignmentManagerMonkeyFactory extends MonkeyFactory { private long gracefulRollingRestartTSSLeepTime; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/UnbalanceMonkeyFactory.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/UnbalanceMonkeyFactory.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/UnbalanceMonkeyFactory.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/UnbalanceMonkeyFactory.java index 28ab7a03be..162ea45bda 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/factories/UnbalanceMonkeyFactory.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/UnbalanceMonkeyFactory.java @@ -23,7 +23,9 @@ import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; import org.apache.hadoop.hbase.chaos.policies.Policy; +import org.apache.yetus.audience.InterfaceAudience; +@InterfaceAudience.Private public class UnbalanceMonkeyFactory extends MonkeyFactory { /** How often to introduce the chaos. If too frequent, sequence of kills on minicluster * can cause test to fail when Put runs out of retries. */ diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/CalmChaosMonkey.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/monkies/CalmChaosMonkey.java similarity index 94% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/CalmChaosMonkey.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/monkies/CalmChaosMonkey.java index bcf7d85ee7..7a45a366bd 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/CalmChaosMonkey.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/monkies/CalmChaosMonkey.java @@ -18,9 +18,12 @@ package org.apache.hadoop.hbase.chaos.monkies; +import org.apache.yetus.audience.InterfaceAudience; + /** * Chaos Monkey that does nothing. */ +@InterfaceAudience.Public public class CalmChaosMonkey extends ChaosMonkey { @Override public void start() throws Exception { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/ChaosMonkey.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/monkies/ChaosMonkey.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/ChaosMonkey.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/monkies/ChaosMonkey.java index 86cbfe5c61..682a0902f5 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/ChaosMonkey.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/monkies/ChaosMonkey.java @@ -19,6 +19,7 @@ package org.apache.hadoop.hbase.chaos.monkies; import org.apache.hadoop.hbase.Stoppable; +import org.apache.yetus.audience.InterfaceAudience; /** * A utility to injects faults in a running cluster. @@ -41,6 +42,7 @@ import org.apache.hadoop.hbase.Stoppable; * ChaosMonkey class is indeed inspired by the Netflix's same-named tool: * http://techblog.netflix.com/2012/07/chaos-monkey-released-into-wild.html */ +@InterfaceAudience.Public public abstract class ChaosMonkey implements Stoppable { public abstract void start() throws Exception; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java index fed51491af..d5ebe21f94 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/monkies/PolicyBasedChaosMonkey.java @@ -27,12 +27,14 @@ import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.IntegrationTestingUtility; import org.apache.hadoop.hbase.chaos.policies.Policy; import org.apache.hadoop.hbase.util.Pair; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Chaos monkey that given multiple policies will run actions against the cluster. */ +@InterfaceAudience.Public public class PolicyBasedChaosMonkey extends ChaosMonkey { private static final Logger LOG = LoggerFactory.getLogger(PolicyBasedChaosMonkey.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/CompositeSequentialPolicy.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/CompositeSequentialPolicy.java similarity index 95% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/CompositeSequentialPolicy.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/CompositeSequentialPolicy.java index 4fefca802a..c8eadbfb27 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/CompositeSequentialPolicy.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/CompositeSequentialPolicy.java @@ -18,10 +18,12 @@ package org.apache.hadoop.hbase.chaos.policies; +import org.apache.yetus.audience.InterfaceAudience; import java.util.Arrays; import java.util.List; /** A policy that runs multiple other policies one after the other */ +@InterfaceAudience.Public public class CompositeSequentialPolicy extends Policy { private List policies; public CompositeSequentialPolicy(Policy... policies) { diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/DoActionsOncePolicy.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/DoActionsOncePolicy.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/DoActionsOncePolicy.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/DoActionsOncePolicy.java index 0d8564d355..03a92e5e66 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/DoActionsOncePolicy.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/DoActionsOncePolicy.java @@ -24,8 +24,10 @@ import java.util.List; import org.apache.hadoop.hbase.chaos.actions.Action; import org.apache.hadoop.util.StringUtils; +import org.apache.yetus.audience.InterfaceAudience; /** A policy which performs a sequence of actions deterministically. */ +@InterfaceAudience.Public public class DoActionsOncePolicy extends PeriodicPolicy { private List actions; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java index 9ffef16a1a..a699b30360 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/PeriodicPolicy.java @@ -20,8 +20,10 @@ package org.apache.hadoop.hbase.chaos.policies; import org.apache.commons.lang3.RandomUtils; import org.apache.hadoop.hbase.util.Threads; +import org.apache.yetus.audience.InterfaceAudience; /** A policy which does stuff every time interval. */ +@InterfaceAudience.Public public abstract class PeriodicPolicy extends Policy { private long periodMs; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicRandomActionPolicy.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/PeriodicRandomActionPolicy.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicRandomActionPolicy.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/PeriodicRandomActionPolicy.java index a0dc89e019..7f1c40fc69 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/PeriodicRandomActionPolicy.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/PeriodicRandomActionPolicy.java @@ -26,11 +26,13 @@ import org.apache.hadoop.hbase.chaos.actions.Action; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.util.Pair; import org.apache.hadoop.util.StringUtils; +import org.apache.yetus.audience.InterfaceAudience; /** * A policy, which picks a random action according to the given weights, * and performs it every configurable period. */ +@InterfaceAudience.Public public class PeriodicRandomActionPolicy extends PeriodicPolicy { private List> actions; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/Policy.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/Policy.java similarity index 96% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/Policy.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/Policy.java index 81267a6568..12a6c652da 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/Policy.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/Policy.java @@ -21,12 +21,14 @@ package org.apache.hadoop.hbase.chaos.policies; import org.apache.hadoop.hbase.IntegrationTestingUtility; import org.apache.hadoop.hbase.chaos.actions.Action; import org.apache.hadoop.hbase.util.StoppableImplementation; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * A policy to introduce chaos to the cluster */ +@InterfaceAudience.Public public abstract class Policy extends StoppableImplementation implements Runnable { protected static final Logger LOG = LoggerFactory.getLogger(Policy.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/TwoConcurrentActionPolicy.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/TwoConcurrentActionPolicy.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/TwoConcurrentActionPolicy.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/TwoConcurrentActionPolicy.java index d801ba81b6..98c7d62189 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/policies/TwoConcurrentActionPolicy.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/policies/TwoConcurrentActionPolicy.java @@ -22,6 +22,7 @@ import org.apache.hadoop.hbase.chaos.actions.Action; import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; import org.apache.hadoop.hbase.util.Threads; import org.apache.hadoop.util.StringUtils; +import org.apache.yetus.audience.InterfaceAudience; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; @@ -32,6 +33,7 @@ import java.util.concurrent.Future; * Chaos Monkey policy that will run two different actions at the same time. * A random action from each array of actions will be chosen and then run in parallel. */ +@InterfaceAudience.Public public class TwoConcurrentActionPolicy extends PeriodicPolicy { private final Action[] actionsOne; private final Action[] actionsTwo; diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java similarity index 98% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java index 504bd628dc..d9c7455697 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java @@ -31,11 +31,13 @@ import org.apache.hadoop.hbase.chaos.factories.MonkeyFactory; import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; import org.apache.hadoop.hbase.util.AbstractHBaseTool; import org.apache.hadoop.util.ToolRunner; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.apache.hbase.thirdparty.com.google.common.collect.Sets; import org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine; +@InterfaceAudience.Public public class ChaosMonkeyRunner extends AbstractHBaseTool { private static final Logger LOG = LoggerFactory.getLogger(ChaosMonkeyRunner.class); diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java similarity index 97% rename from hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java rename to hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java index acdd7b0837..470ebd7aca 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java @@ -27,6 +27,7 @@ import java.util.concurrent.TimeUnit; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.IntegrationTestingUtility; +import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -36,6 +37,7 @@ import org.apache.hbase.thirdparty.com.google.common.util.concurrent.ThreadFacto /** * This class can be used to control chaos monkeys life cycle. */ +@InterfaceAudience.Public public class Monkeys implements Closeable { private static final Logger LOG = LoggerFactory.getLogger(Monkeys.class); -- 2.23.0 From 83a83f23db127041c6bbc132da933cecf344432b Mon Sep 17 00:00:00 2001 From: Lokesh Khurana Date: Tue, 25 Feb 2020 19:19:43 +0530 Subject: [PATCH 2/2] Making MonkeyConstants Public --- .../main/java/org/apache/hadoop/hbase/HBaseClusterManager.java | 3 +-- .../apache/hadoop/hbase/chaos/factories/MonkeyConstants.java | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/hbase-it/src/main/java/org/apache/hadoop/hbase/HBaseClusterManager.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/HBaseClusterManager.java index ed09d17af6..1d361d52d1 100644 --- a/hbase-it/src/main/java/org/apache/hadoop/hbase/HBaseClusterManager.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/HBaseClusterManager.java @@ -44,8 +44,7 @@ import org.slf4j.LoggerFactory; * user the daemon is running as) */ @InterfaceAudience.Public -public class HBaseClusterManager extends Configured implements - org.apache.hadoop.hbase.ClusterManager { +public class HBaseClusterManager extends Configured implements ClusterManager { private static final String SIGKILL = "SIGKILL"; private static final String SIGSTOP = "SIGSTOP"; private static final String SIGCONT = "SIGCONT"; diff --git a/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java index aa7864748e..b8e69b40d6 100644 --- a/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java +++ b/hbase-it/src/main/java/org/apache/hadoop/hbase/chaos/factories/MonkeyConstants.java @@ -22,7 +22,7 @@ import java.util.Arrays; import java.util.HashSet; import java.util.Set; -@InterfaceAudience.Private +@InterfaceAudience.Public public interface MonkeyConstants { String PERIODIC_ACTION1_PERIOD = "sdm.action1.period"; -- 2.23.0