Skip to content

Commit

Permalink
Refactor handler package (#2316)
Browse files Browse the repository at this point in the history
  • Loading branch information
@terrymanu
terrymanu authored Oct 25, 2023
1 parent d45d40b commit 9905251
Show file tree
Hide file tree
Showing 57 changed files with 76 additions and 97 deletions.
2 changes: 1 addition & 1 deletion ...b/infra/handler/sharding/JobInstance.java → ...lasticjob/infra/sharding/JobInstance.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.sharding;
package org.apache.shardingsphere.elasticjob.infra.sharding;

import lombok.EqualsAndHashCode;
import lombok.Getter;
Expand Down
2 changes: 1 addition & 1 deletion ...handler/sharding/JobShardingStrategy.java → ...b/infra/sharding/JobShardingStrategy.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.sharding;
package org.apache.shardingsphere.elasticjob.infra.sharding;

import org.apache.shardingsphere.infra.spi.type.typed.TypedSPI;

Expand Down
6 changes: 3 additions & 3 deletions ...AverageAllocationJobShardingStrategy.java → ...AverageAllocationJobShardingStrategy.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,10 +15,10 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.sharding.impl;
package org.apache.shardingsphere.elasticjob.infra.sharding.impl;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobShardingStrategy;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobShardingStrategy;

import java.util.ArrayList;
import java.util.Collections;
Expand Down
6 changes: 3 additions & 3 deletions ...OdevitySortByNameJobShardingStrategy.java → ...OdevitySortByNameJobShardingStrategy.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,10 +15,10 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.sharding.impl;
package org.apache.shardingsphere.elasticjob.infra.sharding.impl;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobShardingStrategy;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobShardingStrategy;

import java.util.Collections;
import java.util.List;
Expand Down
6 changes: 3 additions & 3 deletions .../RoundRobinByNameJobShardingStrategy.java → .../RoundRobinByNameJobShardingStrategy.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,10 +15,10 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.sharding.impl;
package org.apache.shardingsphere.elasticjob.infra.sharding.impl;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobShardingStrategy;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobShardingStrategy;

import java.util.ArrayList;
import java.util.List;
Expand Down
2 changes: 1 addition & 1 deletion ...threadpool/ElasticJobExecutorService.java → ...threadpool/ElasticJobExecutorService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.threadpool;
package org.apache.shardingsphere.elasticjob.infra.threadpool;

import com.google.common.util.concurrent.MoreExecutors;
import org.apache.commons.lang3.concurrent.BasicThreadFactory;
Expand Down
4 changes: 1 addition & 3 deletions ...concurrent/ExecutorServiceReloadable.java → ...threadpool/ExecutorServiceReloadable.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,11 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.concurrent;
package org.apache.shardingsphere.elasticjob.infra.threadpool;

import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import org.apache.shardingsphere.elasticjob.infra.context.Reloadable;
import org.apache.shardingsphere.elasticjob.infra.handler.threadpool.ElasticJobExecutorService;
import org.apache.shardingsphere.elasticjob.infra.handler.threadpool.JobExecutorThreadPoolSizeProvider;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;

import java.util.Optional;
Expand Down
2 changes: 1 addition & 1 deletion ...ol/JobExecutorThreadPoolSizeProvider.java → ...ol/JobExecutorThreadPoolSizeProvider.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.threadpool;
package org.apache.shardingsphere.elasticjob.infra.threadpool;

import org.apache.shardingsphere.infra.spi.annotation.SingletonSPI;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPI;
Expand Down
4 changes: 2 additions & 2 deletions ...ageJobExecutorThreadPoolSizeProvider.java → ...ageJobExecutorThreadPoolSizeProvider.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,9 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.threadpool.type;
package org.apache.shardingsphere.elasticjob.infra.threadpool.type;

import org.apache.shardingsphere.elasticjob.infra.handler.threadpool.JobExecutorThreadPoolSizeProvider;
import org.apache.shardingsphere.elasticjob.infra.threadpool.JobExecutorThreadPoolSizeProvider;

/**
* Job executor pool size provider with use CPU available processors.
Expand Down
4 changes: 2 additions & 2 deletions ...eadJobExecutorThreadPoolSizeProvider.java → ...eadJobExecutorThreadPoolSizeProvider.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,9 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.threadpool.type;
package org.apache.shardingsphere.elasticjob.infra.threadpool.type;

import org.apache.shardingsphere.elasticjob.infra.handler.threadpool.JobExecutorThreadPoolSizeProvider;
import org.apache.shardingsphere.elasticjob.infra.threadpool.JobExecutorThreadPoolSizeProvider;

/**
* Job executor pool size provider with single thread.
Expand Down
2 changes: 1 addition & 1 deletion ...resources/META-INF/services/org.apache.shardingsphere.elasticjob.infra.context.Reloadable
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,4 +15,4 @@
# limitations under the License.
#

org.apache.shardingsphere.elasticjob.infra.concurrent.ExecutorServiceReloadable
org.apache.shardingsphere.elasticjob.infra.threadpool.ExecutorServiceReloadable
20 changes: 0 additions & 20 deletions .../services/org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobShardingStrategy
View file

This file was deleted.

5 changes: 3 additions & 2 deletions ...eadpool.JobExecutorThreadPoolSizeProvider → ...ticjob.infra.sharding.JobShardingStrategy
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,5 +15,6 @@
# limitations under the License.
#

org.apache.shardingsphere.elasticjob.infra.handler.threadpool.type.CPUUsageJobExecutorThreadPoolSizeProvider
org.apache.shardingsphere.elasticjob.infra.handler.threadpool.type.SingleThreadJobExecutorThreadPoolSizeProvider
org.apache.shardingsphere.elasticjob.infra.sharding.impl.AverageAllocationJobShardingStrategy
org.apache.shardingsphere.elasticjob.infra.sharding.impl.OdevitySortByNameJobShardingStrategy
org.apache.shardingsphere.elasticjob.infra.sharding.impl.RoundRobinByNameJobShardingStrategy
7 changes: 4 additions & 3 deletions ...sticjob.infra.listener.ElasticJobListener → ...eadpool.JobExecutorThreadPoolSizeProvider
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,14 +5,15 @@
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
#
# http://www.apache.org/licenses/LICENSE-2.0
#
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

org.apache.shardingsphere.elasticjob.infra.listener.fixture.FooElasticJobListener
org.apache.shardingsphere.elasticjob.infra.threadpool.type.CPUUsageJobExecutorThreadPoolSizeProvider
org.apache.shardingsphere.elasticjob.infra.threadpool.type.SingleThreadJobExecutorThreadPoolSizeProvider
2 changes: 1 addition & 1 deletion ...fra/handler/sharding/JobInstanceTest.java → ...icjob/infra/sharding/JobInstanceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.sharding;
package org.apache.shardingsphere.elasticjob.infra.sharding;

import org.apache.shardingsphere.elasticjob.infra.env.IpUtils;
import org.apache.shardingsphere.elasticjob.infra.yaml.YamlEngine;
Expand Down
6 changes: 3 additions & 3 deletions ...ageAllocationJobShardingStrategyTest.java → ...ageAllocationJobShardingStrategyTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,10 +15,10 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.sharding.impl;
package org.apache.shardingsphere.elasticjob.infra.sharding.impl;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobShardingStrategy;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobShardingStrategy;
import org.junit.jupiter.api.Test;

import java.util.Arrays;
Expand Down
4 changes: 2 additions & 2 deletions ...itySortByNameJobShardingStrategyTest.java → ...itySortByNameJobShardingStrategyTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,9 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.sharding.impl;
package org.apache.shardingsphere.elasticjob.infra.sharding.impl;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.junit.jupiter.api.Test;

import java.util.Arrays;
Expand Down
4 changes: 2 additions & 2 deletions ...eServerByNameJobShardingStrategyTest.java → ...eServerByNameJobShardingStrategyTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,9 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.sharding.impl;
package org.apache.shardingsphere.elasticjob.infra.sharding.impl;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.junit.jupiter.api.Test;

import java.util.Arrays;
Expand Down
3 changes: 1 addition & 2 deletions ...urrent/ElasticJobExecutorServiceTest.java → ...adpool/ElasticJobExecutorServiceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,8 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.concurrent;
package org.apache.shardingsphere.elasticjob.infra.threadpool;

import org.apache.shardingsphere.elasticjob.infra.handler.threadpool.ElasticJobExecutorService;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.Test;

Expand Down
2 changes: 1 addition & 1 deletion ...urrent/ExecutorServiceReloadableTest.java → ...adpool/ExecutorServiceReloadableTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.concurrent;
package org.apache.shardingsphere.elasticjob.infra.threadpool;

import lombok.SneakyThrows;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
Expand Down
4 changes: 2 additions & 2 deletions ...obExecutorThreadPoolSizeProviderTest.java → ...obExecutorThreadPoolSizeProviderTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,9 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.threadpool.type;
package org.apache.shardingsphere.elasticjob.infra.threadpool.type;

import org.apache.shardingsphere.elasticjob.infra.handler.threadpool.JobExecutorThreadPoolSizeProvider;
import org.apache.shardingsphere.elasticjob.infra.threadpool.JobExecutorThreadPoolSizeProvider;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import org.junit.jupiter.api.Test;

Expand Down
4 changes: 2 additions & 2 deletions ...obExecutorThreadPoolSizeProviderTest.java → ...obExecutorThreadPoolSizeProviderTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,9 @@
* limitations under the License.
*/

package org.apache.shardingsphere.elasticjob.infra.handler.threadpool.type;
package org.apache.shardingsphere.elasticjob.infra.threadpool.type;

import org.apache.shardingsphere.elasticjob.infra.handler.threadpool.JobExecutorThreadPoolSizeProvider;
import org.apache.shardingsphere.elasticjob.infra.threadpool.JobExecutorThreadPoolSizeProvider;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import org.junit.jupiter.api.Test;

Expand Down
2 changes: 1 addition & 1 deletion ...rg/apache/shardingsphere/elasticjob/kernel/internal/election/ElectionListenerManager.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

package org.apache.shardingsphere.elasticjob.kernel.internal.election;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.kernel.internal.listener.AbstractListenerManager;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import org.apache.shardingsphere.elasticjob.kernel.internal.server.ServerNode;
Expand Down
2 changes: 1 addition & 1 deletion ...rg/apache/shardingsphere/elasticjob/kernel/internal/failover/FailoverListenerManager.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

package org.apache.shardingsphere.elasticjob.kernel.internal.failover;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO;
import org.apache.shardingsphere.elasticjob.infra.yaml.YamlEngine;
import org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationNode;
Expand Down
2 changes: 1 addition & 1 deletion ...n/java/org/apache/shardingsphere/elasticjob/kernel/internal/failover/FailoverService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

import com.google.common.base.Strings;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobScheduleController;
Expand Down
2 changes: 1 addition & 1 deletion ...n/java/org/apache/shardingsphere/elasticjob/kernel/internal/instance/InstanceService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

package org.apache.shardingsphere.elasticjob.kernel.internal.instance;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.yaml.YamlEngine;
import org.apache.shardingsphere.elasticjob.kernel.internal.server.ServerService;
import org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodeStorage;
Expand Down
2 changes: 1 addition & 1 deletion .../main/java/org/apache/shardingsphere/elasticjob/kernel/internal/schedule/JobRegistry.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.kernel.internal.listener.ListenerNotifierManager;
import org.apache.shardingsphere.elasticjob.reg.base.CoordinatorRegistryCenter;

Expand Down
2 changes: 1 addition & 1 deletion ...main/java/org/apache/shardingsphere/elasticjob/kernel/internal/schedule/JobScheduler.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
import org.apache.shardingsphere.elasticjob.error.handler.JobErrorHandlerPropertiesValidator;
import org.apache.shardingsphere.elasticjob.executor.ElasticJobExecutor;
import org.apache.shardingsphere.elasticjob.infra.exception.JobSystemException;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.listener.ElasticJobListener;
import org.apache.shardingsphere.elasticjob.kernel.api.listener.AbstractDistributeOnceElasticJobListener;
import org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
Expand Down
2 changes: 1 addition & 1 deletion ...src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/server/ServerNode.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

package org.apache.shardingsphere.elasticjob.kernel.internal.server;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodePath;
import org.apache.shardingsphere.elasticjob.infra.env.IpUtils;
Expand Down
2 changes: 1 addition & 1 deletion ...rg/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionContextService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import org.apache.shardingsphere.elasticjob.infra.context.ShardingItemParameters;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.listener.ShardingContexts;
import org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
Expand Down
2 changes: 1 addition & 1 deletion .../java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

import com.google.common.base.Strings;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.listener.ShardingContexts;
import org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
Expand Down
4 changes: 2 additions & 2 deletions ...n/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ShardingService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import org.apache.shardingsphere.elasticjob.kernel.internal.util.BlockUtils;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobShardingStrategy;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobShardingStrategy;
import org.apache.shardingsphere.elasticjob.infra.yaml.YamlEngine;
import org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import org.apache.shardingsphere.elasticjob.kernel.internal.election.LeaderService;
Expand Down
2 changes: 1 addition & 1 deletion ...c/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/trigger/TriggerNode.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

package org.apache.shardingsphere.elasticjob.kernel.internal.trigger;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodePath;

Expand Down
2 changes: 1 addition & 1 deletion ...pache/shardingsphere/elasticjob/kernel/internal/config/RescheduleListenerManagerTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

package org.apache.shardingsphere.elasticjob.kernel.internal.config;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.kernel.fixture.LiteYamlConstants;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobScheduleController;
Expand Down
2 changes: 1 addition & 1 deletion ...pache/shardingsphere/elasticjob/kernel/internal/election/ElectionListenerManagerTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

package org.apache.shardingsphere.elasticjob.kernel.internal.election;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobScheduleController;
import org.apache.shardingsphere.elasticjob.kernel.internal.server.ServerService;
Expand Down
2 changes: 1 addition & 1 deletion ...java/org/apache/shardingsphere/elasticjob/kernel/internal/election/LeaderServiceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

package org.apache.shardingsphere.elasticjob.kernel.internal.election;

import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.kernel.internal.election.LeaderService.LeaderElectionExecutionCallback;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobScheduleController;
Expand Down
2 changes: 1 addition & 1 deletion ...pache/shardingsphere/elasticjob/kernel/internal/failover/FailoverListenerManagerTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.failover;

import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import org.apache.shardingsphere.elasticjob.infra.handler.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.infra.sharding.JobInstance;
import org.apache.shardingsphere.elasticjob.kernel.fixture.LiteYamlConstants;
import org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import org.apache.shardingsphere.elasticjob.kernel.internal.instance.InstanceNode;
Expand Down
Loading

0 comments on commit 9905251

Please sign in to comment.