File tree Expand file tree Collapse file tree
api/src/main/java/marquez/jobs Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2626public class DbRetentionJob extends AbstractScheduledService implements Managed {
2727 private static final Duration NO_DELAY = Duration .ofMinutes (0 );
2828
29- /* The number of rows deleted per batch . */
29+ /* The retention policy frequency . */
3030 private final int frequencyMins ;
3131
3232 /* The number of rows deleted per batch. */
@@ -45,10 +45,11 @@ public class DbRetentionJob extends AbstractScheduledService implements Managed
4545 */
4646 public DbRetentionJob (
4747 @ NonNull final Jdbi jdbi , @ NonNull final DbRetentionConfig dbRetentionConfig ) {
48+ this .frequencyMins = dbRetentionConfig .getFrequencyMins ();
4849 this .numberOfRowsPerBatch = dbRetentionConfig .getNumberOfRowsPerBatch ();
4950 this .retentionDays = dbRetentionConfig .getRetentionDays ();
5051
51- // Open connection .
52+ // Connection to database retention policy will be applied .
5253 this .jdbi = jdbi ;
5354
5455 // Define fixed schedule with no delay.
You can’t perform that action at this time.
0 commit comments