AddedFieldDefinition

Defines the field to add on a record.

• type: object
• required: ["type","path","value"]

type

• Required: Yes
• type: string
• enum: ["AddedFieldDefinition"]

path

List of strings defining the path where to add the value on the record.

• Required: Yes
• type: array

Examples:

- segment_id

- metadata
- segment_id

• items:

  • type: string

value

Value of the new field. Use {{ record['existing_field'] }} syntax to refer to other fields in the record.

• Required: Yes
• type: string
• Available variables: config, record, stream_interval, stream_partition, stream_slice

Examples:

{{ record['updates'] }}

{{ record['MetaData']['LastUpdatedTime'] }}

{{ stream_partition['segment_id'] }}

value_type

Type of the value. If not specified, the type will be inferred from the value.

• Required: No
• Allowed type: ValueType

$parameters

• Required: No
• type: object