This is an automated email from the ASF dual-hosted git repository.
abhishekrb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 612c48f3a8e simplify SimpleQueryableIndex constructor (#17710)
add f776f33069d Scheduled batch supervisor (#17353)
No new revisions were added by this update.
Summary of changes:
indexing-service/pom.xml | 5 +
.../org/apache/druid/guice/SupervisorModule.java | 4 +-
.../druid/indexing/overlord/DruidOverlord.java | 4 +
.../scheduledbatch/BatchSupervisorTaskReport.java | 73 ++++
.../scheduledbatch/BatchSupervisorTaskStatus.java | 78 +++++
.../scheduledbatch/CronSchedulerConfig.java | 52 +++
.../scheduledbatch/CronSchedulerUtils.java | 76 +++++
.../scheduledbatch/QuartzCronSchedulerConfig.java | 103 ++++++
.../ScheduledBatchStatusTracker.java | 171 ++++++++++
.../scheduledbatch/ScheduledBatchSupervisor.java | 117 +++++++
.../ScheduledBatchSupervisorSpec.java | 201 +++++++++++
.../ScheduledBatchSupervisorStatus.java | 92 ++++++
.../scheduledbatch/ScheduledBatchTaskManager.java | 344 +++++++++++++++++++
.../scheduledbatch/UnixCronSchedulerConfig.java | 118 +++++++
.../druid/indexing/overlord/http/OverlordTest.java | 2 +
.../QuartzCronSchedulerConfigTest.java | 133 ++++++++
.../ScheduledBatchStatusTrackerTest.java | 233 +++++++++++++
.../ScheduledBatchSupervisorSpecTest.java | 245 ++++++++++++++
.../ScheduledBatchSupervisorTest.java | 147 +++++++++
.../ScheduledBatchTaskManagerTest.java | 367 +++++++++++++++++++++
.../UnixCronSchedulerConfigTest.java | 122 +++++++
licenses.yaml | 22 ++
pom.xml | 1 +
.../java/org/apache/druid/cli/CliOverlord.java | 2 +
24 files changed, 2711 insertions(+), 1 deletion(-)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/BatchSupervisorTaskReport.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/BatchSupervisorTaskStatus.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/CronSchedulerConfig.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/CronSchedulerUtils.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/QuartzCronSchedulerConfig.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchStatusTracker.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchSupervisor.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchSupervisorSpec.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchSupervisorStatus.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchTaskManager.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/scheduledbatch/UnixCronSchedulerConfig.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/scheduledbatch/QuartzCronSchedulerConfigTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchStatusTrackerTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchSupervisorSpecTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchSupervisorTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/scheduledbatch/ScheduledBatchTaskManagerTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/scheduledbatch/UnixCronSchedulerConfigTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
