Reads the entire contents of a KeyValueTable, outputting records with a 'key' field and a 'value' field. Both fields are of type bytes.

Use Case

The source is used whenever you need to read from a KeyValueTable in batch. For example, you may want to periodically dump the contents of a KeyValueTable to a Table.


name: KeyValueTable name. If the table does not already exist, it will be created. (Macro-enabled)


This example reads from a KeyValueTable named 'items':

    "name": "KVTable",
    "type": "batchsource",
    "properties": {
        "name": "items"

It outputs records with this schema:

| field name | type  |
| key        | bytes |
| value      | bytes |

  • CDAP Pipelines Plugin Type: batchsource
  • CDAP Pipelines Version: 1.7.0