EXECUTE DATA LOADER FOR KAFKA

EXECUTE DATA LOADER executes a data loader. It attempts to load all data from Kafka topics and partitions mentioned in the copy statement of Create Data Loader for Kafka. By default, executing the loader commits the transaction.

Syntax

EXECUTE DATA LOADER [schema.]name

Arguments

schema

Schema containing the data loader. The default schema is public.

name

Name of the data loader.

Privileges

Read privileges to the source location.

Non-superuser:

• Owner or EXECUTE privilege on the data loader.
• Write privilege on the table.

Example

Execute a data loader once:

=> EXECUTE DATA LOADER sales_dl;
 Rows Loaded 
-------------
           5
(1 row)