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.