CRUD-Enabled Stages

The following stages recognize CRUD operations stored in record header attributes and can perform writes based on those values. Some stages also provide CRUD-related properties.
CRUD-Enabled Stage Supported Operations Stage Processing
JDBC Tee processor
  • INSERT
  • UPDATE
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute
  • Default Operation and Unsupported Operation Handling properties in the stage

Includes a Change Log property that enables processing records based on the CDC-enabled origin that you use. For more information, see Define the CRUD Operation.

Couchbase destination
  • INSERT
  • UPDATE
  • UPSERT
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute
  • Default Write Operation and Unsupported Operation Handling properties in the stage

For more information, see Define the CRUD Operation.

Databricks Delta Lake destination
  • INSERT
  • UPDATE
  • UPSERT
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute

For more information, see Defining the CRUD Operation for CDC Data.

Elasticsearch destination
  • CREATE (INSERT)
  • UPDATE
  • INDEX (UPSERT)
  • DELETE
  • UPDATE with doc_as_upsert (MERGE)
Determines the operation to use based on:
  • sdc.operation.type record header attribute
  • Default Operation and Unsupported Operation Handling properties in the stage

For more information, see Define the CRUD Operation.

Google BigQuery (Enterprise) destination
  • INSERT
  • UPDATE
  • UPSERT
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute

For more information, see Define the CRUD Operation.

GPSS Producer destination
  • INSERT
  • UPDATE
  • MERGE
Determines the operation to use based on:
  • sdc.operation.type record header attribute
  • Default Operation and Unsupported Operation Handling properties in the stage

For more information, see Define the CRUD Operation.

JDBC Producer destination
  • INSERT
  • UPDATE
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute
  • Default Operation and Unsupported Operation Handling properties in the stage

Includes a Change Log property that enables processing records based on the CDC-enabled origin that you use. For more information, see Define the CRUD Operation.

Kudu destination
  • INSERT
  • UPDATE
  • UPSERT
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute
  • Default Operation and Unsupported Operation Handling properties in the stage

For more information, see Define the CRUD Operation.

MapR DB JSON destination
  • INSERT
  • UPDATE
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute
  • Insert API and Set API properties in the stage

For more information, see Writing to MapR DB JSON.

MongoDB destination
  • INSERT
  • UPDATE
  • REPLACE
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute
  • Upsert property in the stage

For more information, see Define the CRUD Operation.

Redis destination
  • INSERT
  • UPDATE
  • REPLACE
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute

For more information, see Define the CRUD Operation.

Salesforce destination
  • INSERT
  • UPDATE
  • UPSERT
  • DELETE
  • UNDELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute
  • Default Operation and Unsupported Operation Handling properties in the stage

For more information, see Define the CRUD Operation.

Snowflake destination
  • INSERT
  • UPDATE
  • DELETE
Determines the operation to use based on:
  • sdc.operation.type record header attribute

For more information, see Define the CRUD Operation.