ALTER DATA LOADER FOR KAFKA SOURCE
Changes the properties of a data loader.
Changes the properties of a data loader created as mentioned in CREATE DATA LOADER FOR KAFKA.
Syntax
ALTER DATA LOADER [schema.]name {
SET TO copy-statement
| RETENTION INTERVAL monitoring-retention
| RENAME TO new-name
| OWNER TO user
| ENABLE | DISABLE
}
Arguments
schema- Schema containing the data loader. The default schema is
public. name- Name of the data loader to alter.
SET TOcopy-statement- The new COPY statement that the loader executes.
Examples
ALTER DATA LOADER loader1 SET TO COPY table1 SOURCE\
KafkaSource(stream='topic0,topic1,newtopic|0|-2',\
brokers='localhost:9093',stop_on_eof=true) PARSER KafkaJSONParser()
Disable the data loader.
ALTER DATA LOADER <schema.dataloadername> DISABLE;
Rename the data loader.
ALTER DATA LOADER <schema.dataloadername> RENAME TO ;
Change the owner of the data loader.
ALTER DATA LOADER <schema.dataloadername> OWNER TO ;
RETENTION INTERVALmonitoring-retention- How long to keep records in the events table. DATA_LOADER_EVENTS records events for all data loaders, but each data loader has its own retention interval.
Default:
14 days RENAME TOnew-name- New name for the data loader.
OWNER TOuser- New owner for the data loader.
ENABLE | DISABLE- Whether the data loader can be executed. Calling EXECUTE DATA LOADER on a disabled data loader returns an error.
Privileges
Non-superuser:
- USAGE on the schema.
- Owner or ALTER privilege on the data loader.