As you want to apply some data replacement on those columns, I suggest you try it with applying a reduction to calculate what you need while skipping invalid values (see setIgnoreInvalid) and then a transformation to replace the invalid values.
As you want to apply some data replacement on those columns, I suggest you try it with applying a reduction to calculate what you need while skipping invalid values (see setIgnoreInvalid) and then a transformation to replace the invalid values.