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 TO
copy-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 INTERVAL
monitoring-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 TO
new-name
- New name for the data loader.
OWNER TO
user
- 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.