forked from D-Net/dnet-hadoop
minor changes
This commit is contained in:
parent
dade7d5bb8
commit
8a5ba8df45
|
@ -112,12 +112,6 @@ public class Constants {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public static Instance getInstance(Qualifier qualifier) {
|
|
||||||
Instance instance = new Instance();
|
|
||||||
instance.setInstancetype(qualifier);
|
|
||||||
return instance;
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void removeOutputDir(SparkSession spark, String path) {
|
public static void removeOutputDir(SparkSession spark, String path) {
|
||||||
HdfsSupport.remove(path, spark.sparkContext().hadoopConfiguration());
|
HdfsSupport.remove(path, spark.sparkContext().hadoopConfiguration());
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue