# Metadata

> Metadata transform plugin

## Description
Metadata transform plugin for adding metadata fields to data

## Available Metadata

|    Key    | DataType | Description                                                                                              |
|:---------:|:--------:|:---------------------------------------------------------------------------------------------------------|
| Database  |  string  | Name of the table that contain the row.                                                                  |
|   Table   |  string  | Name of the table that contain the row.                                                                  |
|  RowKind  |  string  | The type of operation                                                                                    |
| EventTime |   Long   | The time at which the connector processed the event.And the data should be milliseconds                  |
|   Delay   |   Long   | The difference between data extraction time and database change time.And the data should be milliseconds |
| Partition |  string  | Contains the partition field of the corresponding number table of the row, multiple using `,` join       |

### note
    `Delay` `EventTime` only worked on cdc series connectors for now , except TiDB-CDC

## Options

|      name       | type | required | default value | Description                                                               |
|:---------------:|------|----------|---------------|---------------------------------------------------------------------------|
| metadata_fields | map  | yes      |               | A mapping metadata input fields and their corresponding output fields.    |

### metadata_fields [map]

A mapping between metadata fields and their respective output fields. 

```hocon
metadata_fields {
  Database = c_database
  Table = c_table
  RowKind = c_rowKind
  EventTime = c_ts_ms
  Delay = c_delay
}
```

## Examples

```yaml

env {
    parallelism = 1
    job.mode = "STREAMING"
    checkpoint.interval = 5000
    read_limit.bytes_per_second = 7000000
    read_limit.rows_per_second = 400
}

source {
    MySQL-CDC {
        plugin_output = "customers_mysql_cdc"
        server-id = 5652
        username = "root"
        password = "zdyk_Dev@2024"
        table-names = ["source.user"]
        url = "jdbc:mysql://172.16.17.123:3306/source"
    }
}

transform {
  Metadata {
    metadata_fields {
      Database = database
      Table = table
      RowKind = rowKind
      EventTime = ts_ms
      Delay = delay
    }
    plugin_output = "trans_result"
  }
}

sink {
  Console {
    plugin_input = "custom_name"
  }
}

```