这里有一个Groovy选项，应该可以做到这一点：

// Sample Groovy code
records = sdc.records
String keys = ""
String values = ""
for (record in records) {
try {
      keys = "";
      values = "";
  
      for(String key: record.value.keySet()) {
        keys = keys + (keys==""?"":", ") + key;
        values = values + (values==""?"":", ") + record.value[key];
  }
  record.value = ["keys":keys, "values": values];

    // Write a record to the processor output
        sdc.output.write(record)
    } catch (e) {
    // Write a record to the error pipeline
        sdc.log.error(e.toString(), e)
        sdc.error.write(record, e.toString())
    }
}

我强烈建议您学习Groovy、JavaScript或Python的基础知识。对这种案子应该有很大帮助。