new parametrized implementation for country propagation
This commit is contained in:
parent
03f7cb6402
commit
6dfdba9ef7
|
@ -123,7 +123,7 @@ public class SparkCountryPropagationJob2 {
|
||||||
.option("compression", "gzip")
|
.option("compression", "gzip")
|
||||||
.text(outputPath);
|
.text(outputPath);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
private static <R extends Result> Dataset<Row> getPotentialResultToUpdate(SparkSession spark, String inputPath,
|
private static <R extends Result> Dataset<Row> getPotentialResultToUpdate(SparkSession spark, String inputPath,
|
||||||
|
|
Loading…
Reference in New Issue