/
API Merge

API Merge

alter_merge_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216) )

alter_merge_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216) )

alter_merge_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLES“ ARRAY )

alter_merge_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216) )

alter_merge_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216) )

alter_merge_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLES“ ARRAY )

Alters the schedule of the merge tasks based on the UI merge settings. You can alter one or more merge tasks based on the procedure parameters.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE : Name of the table

  • P_TABLES : Array of table names

alter_task_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216)

“P_SCHEDULE“ VARCHAR(16777216))

alter_task_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_SCHEDULE“ VARCHAR(16777216) )

alter_task_schedule( “P_DB“ VARCHAR(16777216)

“P_SCHEDULE“ VARCHAR(16777216) )

alter_task_schedule( “P_SCHEDULE“ VARCHAR(16777216) )

alter_task_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216)

“P_SCHEDULE“ VARCHAR(16777216))

alter_task_schedule( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_SCHEDULE“ VARCHAR(16777216) )

alter_task_schedule( “P_DB“ VARCHAR(16777216)

“P_SCHEDULE“ VARCHAR(16777216) )

alter_task_schedule( “P_SCHEDULE“ VARCHAR(16777216) )

Alters the schedule of the merge tasks based on the parameter P_SCHEDULE. You can alter one or more merge tasks based on the procedure parameters.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE : Name of the table

  • P_SCHEDULE : String in CRON format

alter_task_warehouse( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216)

“P_WAREHOUSE“ VARCHAR(16777216))

alter_task_warehouse( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_WAREHOUSE“ VARCHAR(16777216) )

alter_task_warehouse( “P_DB“ VARCHAR(16777216)

“P_WAREHOUSE“ VARCHAR(16777216) )

alter_task_warehouse( “P_WAREHOUSE“ VARCHAR(16777216) )

alter_task_warehouse( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216)

“P_WAREHOUSE“ VARCHAR(16777216))

alter_task_warehouse( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_WAREHOUSE“ VARCHAR(16777216) )

alter_task_warehouse( “P_DB“ VARCHAR(16777216)

“P_WAREHOUSE“ VARCHAR(16777216) )

alter_task_warehouse( “P_WAREHOUSE“ VARCHAR(16777216) )

Alters the merge tasks in the warehouse based on the parameter P_WAREHOUSE. You can alter one or more merge tasks based on the procedure parameters.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE : Name of the table

  • P_WAREHOUSE : Name of the warehouse

alter_task_timeout( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216)

“P_TIMEOUT“ VARCHAR(16777216))

alter_task_timeout( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TIMEOUT“ VARCHAR(16777216) )

alter_task_timeout( “P_DB“ VARCHAR(16777216)

“P_TIMEOUT“ VARCHAR(16777216) )

alter_task_timeout( “P_TIMEOUT“ VARCHAR(16777216) )

alter_task_timeout( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216)

“P_TIMEOUT“ VARCHAR(16777216))

alter_task_timeout( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TIMEOUT“ VARCHAR(16777216) )

alter_task_timeout( “P_DB“ VARCHAR(16777216)

“P_TIMEOUT“ VARCHAR(16777216) )

alter_task_timeout( “P_TIMEOUT“ VARCHAR(16777216) )

Alter merge tasks user timeout based on P_TIMEOUT parameter. You can alter one or multiple merge tasks based on procedure parameters.

Parameters:

  • P_DB → Database

  • P_SOURCE → Name of the source schema

  • P_TABLE → Name of the table

  • P_TIMEOUT → Timeout in milliseconds

deploy_merge( )

deploy_merge( “P_DB“ VARCHAR(16777216))

deploy_merge( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216))

deploy_merge( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216))

deploy_merge( )

deploy_merge( “P_DB“ VARCHAR(16777216))

deploy_merge( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216))

deploy_merge( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216))

Creates merge tasks for one or more tables.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE Name of the table

drop_glue_objects( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216)

“P_TYPE“ VARCHAR(16777216)

“P_OBJECT_DB“ VARCHAR(16777216)

“P_OBJECT_SCHEMA“ VARCHAR(16777216)

“P_OBJECT“ VARCHAR(16777216) )

drop_glue_objects( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TYPE“ VARCHAR(16777216) )

drop_glue_objects( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TABLE“ VARCHAR(16777216)

“P_TYPE“ VARCHAR(16777216)

“P_OBJECT_DB“ VARCHAR(16777216)

“P_OBJECT_SCHEMA“ VARCHAR(16777216)

“P_OBJECT“ VARCHAR(16777216) )

drop_glue_objects( “P_DB“ VARCHAR(16777216)

“P_SOURCE“ VARCHAR(16777216)

“P_TYPE“ VARCHAR(16777216) )

Drops a Glue object based on the defined parameters.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE : Name of the table

  • P_TYPE : Type of object

  • P_OBJECT_DB : Name of the object database

  • P_OBJECT_SCHEMA : Name of the object source schema

  • P_OBJECT Name of the object

drop_glue_tasks("P_DB" VARCHAR(16777216), "P_SOURCE" VARCHAR(16777216))

core.drop_glue_views("P_DB" VARCHAR(16777216), "P_SOURCE" VARCHAR(16777216))

core.drop_glue_streams("P_DB" VARCHAR(16777216), "P_SOURCE" VARCHAR(16777216))

drop_glue_tasks("P_DB" VARCHAR(16777216), "P_SOURCE" VARCHAR(16777216))

core.drop_glue_views("P_DB" VARCHAR(16777216), "P_SOURCE" VARCHAR(16777216))

core.drop_glue_streams("P_DB" VARCHAR(16777216), "P_SOURCE" VARCHAR(16777216))

Drops all Glue tasks, streams, or views in the schema.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

core.execute_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216),
"P_MERGE" VARCHAR(16777216))

core.execute_cluster_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216),
"P_MERGE" VARCHAR(16777216),
"P_CLUSTER_DELETE" VARCHAR(16777216),
"P_APP_NAME" VARCHAR(16777216))

core.execute_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216),
"P_MERGE" VARCHAR(16777216))

core.execute_cluster_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216),
"P_MERGE" VARCHAR(16777216),
"P_CLUSTER_DELETE" VARCHAR(16777216),
"P_APP_NAME" VARCHAR(16777216))

Execute merge procedure or merge procedure with cluster delete sentence

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE : Name of the table

  • P_MERGE : Definition of the merge sentence

  • P_CLUSTER_DELETE : Definition of the cluster delete sentence

  • P_APP_NAME : Application name

core.execute_merge_task( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216))

core.execute_merge_task( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216))

Executes merge task.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE : Name of the table

core.suspend_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216) ,
"P_TABLES" ARRAY)

core.suspend_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216))

core.suspend_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216) )

core.suspend_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216) ,
"P_TABLES" ARRAY)

core.suspend_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216))

core.suspend_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216) )

Suspends one or more merge tasks based on the parameters.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE : Name of the table

  • P_TABLES : Array of table names

core.resume_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216) ,
"P_TABLES" ARRAY)

core.resume_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216))

core.resume_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216) )

core.resume_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216) ,
"P_TABLES" ARRAY)

core.resume_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216))

core.resume_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216) )

Resumes one or more merge tasks based on the parameters.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE : Name of the table

  • P_TABLES : Array of table names

core.redeploy_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216) )

core.redeploy_merge( "P_DB" VARCHAR(16777216),
"P_SOURCE" VARCHAR(16777216),
"P_TABLE" VARCHAR(16777216) )

Recreate the merge task, the merge table and stream. Data in merge table are truncated.

Parameters:

  • P_DB : Database

  • P_SOURCE : Name of the source schema

  • P_TABLE : Name of the table

Examples:

call core.suspend_merge('<database_name>','<schema_name>','<table_name>'); call core.resume_merge('<database_name>','<schema_name>');