This commit is contained in:
parent
231ed85aa1
commit
ec30ec0d29
|
@ -107,7 +107,7 @@ public class SelectEoscResultsJobStep1 implements Serializable {
|
||||||
(MapFunction<R, Result>) r -> (Result) ResultMapper
|
(MapFunction<R, Result>) r -> (Result) ResultMapper
|
||||||
.map(r, communityMap, df),
|
.map(r, communityMap, df),
|
||||||
Encoders.bean(Result.class))
|
Encoders.bean(Result.class))
|
||||||
.filter(Objects::nonNull)
|
.filter(Objects::nonNull)
|
||||||
.write()
|
.write()
|
||||||
.mode(SaveMode.Overwrite)
|
.mode(SaveMode.Overwrite)
|
||||||
.option("compression", "gzip")
|
.option("compression", "gzip")
|
||||||
|
|
Loading…
Reference in New Issue