[Measures] added new measure (UsageCounts) #214
|
@ -87,7 +87,7 @@ public class SparkAtomicActionUsageJob implements Serializable {
|
||||||
isSparkSessionManaged,
|
isSparkSessionManaged,
|
||||||
spark -> {
|
spark -> {
|
||||||
removeOutputDir(spark, outputPath);
|
removeOutputDir(spark, outputPath);
|
||||||
prepareResults(dbname, spark, outputPath);
|
prepareResults(dbname, spark, workingPath);
|
||||||
prepareActionSet(spark, workingPath, outputPath);
|
prepareActionSet(spark, workingPath, outputPath);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue