Skip to content

Commit 5df3713

Browse files
author
majin.nathan
committed
Improve classes structure
1 parent 4ef0081 commit 5df3713

File tree

3 files changed

+3
-7
lines changed

3 files changed

+3
-7
lines changed

amoro-ams/src/main/java/org/apache/amoro/server/scheduler/TimelyExternalScheduler.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -61,11 +61,6 @@ protected void initHandler(List<DefaultTableRuntime> tableRuntimeList) {
6161
super.initHandler(tableRuntimeList);
6262
}
6363

64-
@Override
65-
protected long getNextExecutingTime(DefaultTableRuntime tableRuntime) {
66-
return 0;
67-
}
68-
6964
@Override
7065
protected boolean enabled(DefaultTableRuntime tableRuntime) {
7166
return tableRuntime.enabled(getAction());

amoro-ams/src/main/java/org/apache/amoro/server/table/DefaultTableRuntime.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import org.apache.amoro.Action;
2222
import org.apache.amoro.ServerTableIdentifier;
2323
import org.apache.amoro.SupportsProcessPlugins;
24+
import org.apache.amoro.TableRuntime;
2425
import org.apache.amoro.config.TableConfiguration;
2526
import org.apache.amoro.process.AmoroProcess;
2627
import org.apache.amoro.process.ProcessFactory;
@@ -41,7 +42,7 @@
4142
import java.util.concurrent.locks.ReentrantLock;
4243
import java.util.stream.Collectors;
4344

44-
public class DefaultTableRuntime extends StatedPersistentBase implements SupportsProcessPlugins {
45+
public class DefaultTableRuntime extends StatedPersistentBase implements TableRuntime, SupportsProcessPlugins {
4546

4647
private static final Logger LOG = LoggerFactory.getLogger(DefaultTableRuntime.class);
4748

amoro-common/src/main/java/org/apache/amoro/SupportsProcessPlugins.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
import org.apache.amoro.process.ProcessFactory;
2323
import org.apache.amoro.process.TableProcessState;
2424

25-
public interface SupportsProcessPlugins extends TableRuntime {
25+
public interface SupportsProcessPlugins {
2626

2727
/**
2828
* Trigger a table process on an action.

0 commit comments

Comments
 (0)