docs: private GenericRecord convertRowToAvroRecord(Schema schema, Row row) {
  		final List<Schema.Field> fields = schema.getFields();
  		final int length = fields.size();
  		final GenericRecord record = new GenericData.Record(schema);
  		for (int i = 0; i < length; i++) {
  			final Schema.Field field = fields.get(i);
  			record.put(i, convertFlinkType(field.schema(), row.getField(i)));
  		}
  		return record;
  	}