[incubator-gobblin] branch master updated: [GOBBLIN-682] Create a new constructor for DatasetCleanerJob.[]

[hu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hutran pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 670a7d0  [GOBBLIN-682] Create a new constructor for DatasetCleanerJob.[]
670a7d0 is described below

commit 670a7d0609ca953a51a472afe03b780fa872499a
Author: suvasude <su...@linkedin.biz>
AuthorDate: Thu Feb 21 13:28:46 2019 -0800

    [GOBBLIN-682] Create a new constructor for DatasetCleanerJob.[]
    
    Closes #2554 from sv2000/datasetCleanerJob
---
 .../gobblin/data/management/retention/DatasetCleanerJob.java       | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java
index fbb6fe5..3a5cc37 100644
--- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java
+++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java
@@ -18,6 +18,7 @@
 package org.apache.gobblin.data.management.retention;
 
 import java.io.IOException;
+import java.util.Properties;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
@@ -45,6 +46,12 @@ public class DatasetCleanerJob extends AbstractJob implements Tool {
     super(id, Logger.getLogger(DatasetCleanerJob.class));
   }
 
+  public DatasetCleanerJob(String id, Properties props) throws IOException {
+    super(id, Logger.getLogger(DatasetCleanerJob.class));
+    this.conf = new Configuration();
+    this.datasetCleaner = new DatasetCleaner(FileSystem.get(getConf()), props);
+  }
+
   public DatasetCleanerJob(String id, Props props) throws IOException {
     super(id, Logger.getLogger(DatasetCleanerJob.class));
     this.conf = new Configuration();