@@ -156,7 +156,7 @@ object NestedRecordCombiner {
156156 * Builds a [[WriterAst ]] node for a primitive copybook field, using the field's index in the
157157 * supplied Spark schema to create a getter function.
158158 *
159- * Returns `None` when the field is absent from the schema (e.g. filtered out during reading).
159+ * Returns a filler when the field is absent from the schema (e.g. filtered out during reading).
160160 */
161161 private def buildPrimitiveNode (p : Primitive , schema : StructType , path : String = " " ): WriterAst = {
162162 val fieldName = p.name
@@ -177,7 +177,7 @@ object NestedRecordCombiner {
177177 PrimitiveField (p, row => row.get(idx))
178178 }
179179 }.getOrElse {
180- log.error(s " Field ' $path${p.name}' is not found in Spark schema. Will be skipped . " )
180+ log.error(s " Field ' $path${p.name}' is not found in Spark schema. Will be replaced by filler . " )
181181 Filler (p.binaryProperties.actualSize)
182182 }
183183 }
@@ -187,7 +187,7 @@ object NestedRecordCombiner {
187187 * extracts an array; for plain groups it extracts the nested Row. In both cases the children
188188 * are built by recursing into the nested Spark StructType.
189189 *
190- * Returns `None` when the field is absent from the schema.
190+ * Returns a filler when the field is absent from the schema.
191191 */
192192 private def buildGroupNode (g : Group , schema : StructType , path : String = " " ): WriterAst = {
193193 val fieldName = g.name
@@ -219,7 +219,7 @@ object NestedRecordCombiner {
219219 }
220220 }
221221 }.getOrElse {
222- log.error(s " Field ' $path${g.name}' is not found in Spark schema. Will be skipped . " )
222+ log.error(s " Field ' $path${g.name}' is not found in Spark schema. Will be replaced by filler . " )
223223 Filler (g.binaryProperties.actualSize)
224224 }
225225 }
0 commit comments