The ALTER SOURCE
command modifies the definition of a source.
alter_option
depends on the operation you want to perform on the source. For all supported clauses, see the sections below.
ADD COLUMN
Parameter or clause | Description |
---|---|
ADD COLUMN | This clause adds a column to the specified source. |
col_name | The name of the new column you want to add to the source. |
data_type | The data type of the newly added column. With the struct data type, you can create a nested table. Elements in a nested table need to be enclosed with angle brackets (<>). |
REFRESH SCHEMA
RENAME TO
Parameter or clause | Description |
---|---|
RENAME TO | This clause changes the name of the source. |
new_source_name | The new name of the source. |
OWNER TO
Parameter or clause | Description |
---|---|
OWNER TO | This clause changes the owner of the source. |
new_user | The new owner you want to assign to the source. |
SET SCHEMA
Parameter or clause | Description |
---|---|
SET SCHEMA | This clause moves the source to a different schema. |
schema_name | The name of the schema to which the source will be moved. |
SET PARALLELISM
Parameter or clause | Description |
---|---|
SET PARALLELISM | This clause controls the degree of parallelism for the targeted streaming job. |
source_name | Should be a shared source. |
parallelism_number | Can be ADAPTIVE or a fixed number (e.g., 1, 2, 3). Setting it to ADAPTIVE expands the job’s parallelism to all available units, while a fixed number locks it at that value. Setting it to 0 is equivalent to ADAPTIVE. The maximum allowed value is determined by the max_parallelism of the job. For more information, see Configuring maximum parallelism. |
SET SOURCE_RATE_LIMIT
SOURCE_RATE_LIMIT
, refer to How to view runtime parameters.
SOURCE_RATE_LIMIT
of the source.To modify the rate limit of the backfilling process, please refer to SET BACKFILL_RATE_LIMIT.SWAP WITH
Parameter | Description |
---|---|
name | The current name of the source to swap. |
target_name | The target name of the source you want to swap with. |