UpdateRecord

UpdateRecord 利用 Lynxus RecordPath 领域专用语言（DSL），让用户指定 Record 中应更新哪些字段。 做法是在 Processor 配置中添加用户自定义属性：属性名必须是要对每条记录求值的 RecordPath 文本，属性值则指定所选记录字段应填入什么值。

指定替换值（即用户自定义属性的值）时，用户可以指定字面量（例如数字 10）、用于引用 FlowFile Attribute 的表达式语言表达式（例如 ${filename}），或者另一个用于从记录本身 取值的 RecordPath 路径。输入的值应被解释为字面量还是 RecordPath 路径，由 属性的值决定。

如果给定的 RecordPath 不匹配输入记录中的任何字段，该属性会被跳过，其余属性仍会正常求值。 如果 RecordPath 恰好匹配一个字段，该字段会被更新为对应的值。如果多个字段匹配该 RecordPath，所有匹配的字段都会被更新。如果替换值本身是一个不匹配的 RecordPath， 字段会被设置为 null。如果这不是期望的行为，可以使用 RecordPath 谓词（predicate） 过滤匹配的字段，使任何字段都不会被选中。更多信息请参阅 RecordPath Predicates。

下面给出一些示例，以便更清楚地说明该 Processor 的行为。以下所有示例都基于下面这组 2 条（JSON）记录：

[
  {
    "id": 17,
    "name": "John",
    "child": {
      "id": "1"
    },
    "siblingIds": [
      4,
      8
    ],
    "siblings": [
      {
        "name": "Jeremy",
        "id": 4
      },
      {
        "name": "Julia",
        "id": 8
      }
    ]
  },
  {
    "id": 98,
    "name": "Jane",
    "child": {
      "id": 2
    },
    "gender": "F",
    "siblingIds": [],
    "siblings": []
  }
]

为简洁起见，我们省略了对应的 schema 以及 RecordReader 和 RecordWriter 的配置。 以下考察为 Processor 配置了不同属性集合时的相应输出。

示例 1 - 用字面量替换

这里我们把每条记录的 name 替换为 'Jeremy'，并把 gender 设为 'M'：

输出如下：

[
  {
    "id": 17,
    "name": "Jeremy",
    "child": {
      "id": "1"
    },
    "gender": "M",
    "siblingIds": [
      4,
      8
    ],
    "siblings": [
      {
        "name": "Jeremy",
        "id": 4
      },
      {
        "name": "Julia",
        "id": 8
      }
    ]
  },
  {
    "id": 98,
    "name": "Jeremy",
    "child": {
      "id": 2
    },
    "gender": "M",
    "siblingIds": [],
    "siblings": []
  }
]

注意，尽管第一条记录在输入中没有 "gender" 字段，更新后仍会在 "child" 字段之后添加 该字段，因为在 schema 中该字段就位于那里。

示例 2 - 用 RecordPath 替换

此示例用记录中另一个字段的值替换某个字段的值。考虑以下属性集合：

输出如下：

[
  {
    "id": 17,
    "name": "Jeremy",
    "child": {
      "id": "1"
    },
    "siblingIds": [
      4,
      8
    ],
    "siblings": [
      {
        "name": "Jeremy",
        "id": 4
      },
      {
        "name": "Julia",
        "id": 8
      }
    ]
  },
  {
    "id": 98,
    "name": null,
    "child": {
      "id": 2
    },
    "gender": "F",
    "siblingIds": [],
    "siblings": []
  }
]

示例 3 - 用相对 RecordPath 替换

在上面的示例中，我们基于另一个 RecordPath 替换了字段的值。那个 RecordPath 是"绝对 RecordPath"，即以"斜杠"字符（/）开头，因此指定的是从"根"（即最外层元素）开始的路径。 但有时我们希望以相对于被更新字段的方式来定义 RecordPath。本示例正是如此：对于 "siblings" 数组中的每个 sibling，我们把该 sibling 的 name 替换为其 id。为此， 给 Processor 配置以下属性：

注意，作为值给出的 RecordPath 以 .. 开头，这是对父级的引用。之所以这样做，是因为 我们要更新的字段是 sibling 的 "name" 字段。要获取对应的 "id" 字段，需要先回到 "name" 字段的父级，再进入其 "id" 子字段。上述示例的输出为：

[
  {
    "id": 17,
    "name": "Jeremy",
    "child": {
      "id": "1"
    },
    "siblingIds": [
      4,
      8
    ],
    "siblings": [
      {
        "name": "Jeremy",
        "id": 4
      },
      {
        "name": "Julia",
        "id": 8
      }
    ]
  },
  {
    "id": 98,
    "name": null,
    "child": {
      "id": 2
    },
    "gender": "F",
    "siblingIds": [],
    "siblings": []
  }
]

示例 4 - 替换多个值

此示例替换所有名为 "id" 的字段的值，无论该字段位于记录层次结构的哪个位置。它使用的 值引用了表达式语言，因此本示例假设传入 FlowFile 有一个名为 "replacement.id"、 值为 "91" 的 Attribute：

输出如下：

[
  {
    "id": 91,
    "name": "John",
    "child": {
      "id": "91"
    },
    "siblingIds": [
      4,
      8
    ],
    "siblings": [
      {
        "name": "Jeremy",
        "id": 91
      },
      {
        "name": "Julia",
        "id": 91
      }
    ]
  },
  {
    "id": 91,
    "name": "Jane",
    "child": {
      "id": 91
    },
    "gender": "F",
    "siblingIds": [],
    "siblings": []
  }
]

还值得注意的是，本例中有些 "id" 字段是 STRING 类型，另一些是 INT 类型。这没有关系， 因为 RecordReader 和 RecordWriter 应当为我们处理这些简单的类型转换。

示例 5 - 使用表达式语言修改值

此示例把所有 'name' 字段的值转换为大写，无论该字段位于记录层次结构的哪个位置。 做法是在表达式语言中引用 'field.value' 变量。也可以访问 field.name 变量和 field.type 变量。

输出如下：

[
  {
    "id": 17,
    "name": "JOHN",
    "child": {
      "id": "1"
    },
    "siblingIds": [
      4,
      8
    ],
    "siblings": [
      {
        "name": "JEREMY",
        "id": 4
      },
      {
        "name": "JULIA",
        "id": 8
      }
    ]
  },
  {
    "id": 98,
    "name": "JANE",
    "child": {
      "id": 2
    },
    "gender": "F",
    "siblingIds": [],
    "siblings": []
  }
]