--- schema_version: "1" id: 18140b5703ddae5253fe6d26ac7a18e9c39488dd1ae843830a77859f29b77746 title: Create Streaming Data Transforms for Consumer Goods Cloud collection: admin version: current locale: en-us portal_url: https://docs.salesforce.com/admin/current/en-us/ind/264-0-0/cg_data_cloud_transforms.md canonical_url: https://help.salesforce.com/s/articleView?id=ind.cg_data_cloud_transforms.htm&release=264.0.0&type=5 source_site: help.salesforce.com content_type: documentation content_hash: 3819e838584bd285d45e5dbc080df05bead439fffec044b4fe22fb98a67bf773 description: Use a streaming data transform to clean ingested data. The source and target data lake objects (DLO) must be different. products: - Consumer Goods release: "264" --- # Create Streaming Data Transforms for Consumer Goods Cloud Use a streaming data transform to clean ingested data. The source and target data lake objects (DLO) must be different. ### Required Editions
Available in: Lightning Experience in Enterprise and Unlimited Editions that have Consumer Goods Cloud enabled
1. On the Data Transforms tab, click **New**. If your org already used the maximum number of transforms, the New button isn’t available. 2. To create a data transform object from an installed data kit, select **Choose From Data Kits**. 3. Select the data transform object from the CG Data Kit, and click **Next**. 4. Enter the data transform name and select the target data lake object as per the table. 5. In Expression, enter an SQL query to specify the records to be processed by the streaming data transform and to define how to map the transformed output to the target DLO. 6. To verify your SQL statement’s syntax, click **Check Syntax**. If a data transform contains syntax errors or validation errors, such as incorrect API names for the source DLO and target DLOs, you can’t save it. These errors appear on the left side. 7. Save the transform. Streaming data transforms are activated immediately when you save them. You can’t change a streaming data transform after you save it. To change a streaming data transform, you must delete it and then create another one. 8. Similarly, create the other data lake streaming data transforms. Retail Execution Base | Data Transform Name | Description | Target DLO | Query | | --- | --- | --- | --- | | Order Billing Address Data Transform | Transform Order's Billing Address into Order\_Billing\_Address\_dlo DLO | Order\_Billing\_Address\_dlo | SELECT Order\_\_dll.Billing\_Address\_Id\_\_c as Address\_Id\_\_c, Order\_\_dll.BillingCity\_\_c as BillingCity\_\_c, Order\_\_dll.BillingCountry\_\_c as BillingCountry\_\_c, Order\_\_dll.BillingLatitude\_\_c as BillingLatitude\_\_c, Order\_\_dll.BillingLongitude\_\_c as BillingLongitude\_\_c, Order\_\_dll.BillingState\_\_c as BillingState\_\_c, Order\_\_dll.BillingStreet\_\_c as BillingStreet\_\_c, Order\_\_dll.BillingPostalCode\_\_c as BillingPostalCode\_\_c FROM Order\_\_dll | | Order Shipping Address Data Transform | Transform Order's Shipping Address into Order\_Shipping\_Address\_dlo DLO | Order\_Shipping\_Address\_dlo | SELECT Order\_\_dll.Id\_\_c as Address\_Id\_\_c, Order\_\_dll.ShippingCity\_\_c as ShippingCity\_\_c, Order\_\_dll.ShippingCountry\_\_c as ShippingCountry\_\_c, Order\_\_dll.ShippingLatitude\_\_c as ShippingLatitude\_\_c, Order\_\_dll.ShippingLongitude\_\_c as ShippingLongitude\_\_c, Order\_\_dll.ShippingState\_\_c as ShippingState\_\_c, Order\_\_dll.ShippingStreet\_\_c as ShippingStreet\_\_c, Order\_\_dll.ShippingPostalCode\_\_c as ShippingPostalCode\_\_c FROM Order\_\_dll | | Account Billing Address Data Transform | Transform Account's Billing Address into Account\_Billing\_Address\_dlo DLO | Account\_Billing\_Address\_dlo | SELECT Account\_\_dll.Billing\_Address\_Id\_\_c as Address\_Id\_\_c, Account\_\_dll.BillingCity\_\_c as BillingCity\_\_c, Account\_\_dll.BillingCountry\_\_c as BillingCountry\_\_c, Account\_\_dll.BillingLatitude\_\_c as BillingLatitude\_\_c, Account\_\_dll.BillingLongitude\_\_c as BillingLongitude\_\_c, Account\_\_dll.BillingState\_\_c as BillingState\_\_c, Account\_\_dll.BillingStreet\_\_c as BillingStreet\_\_c, Account\_\_dll.BillingPostalCode\_\_c as BillingPostalCode\_\_c FROM Account\_\_dll | | Account Shipping Address Data Transform | Transform Account's Shipping Address into Account\_Shipping\_Address\_dlo DLO | Account\_Shipping\_Address\_dlo | SELECT Account\_\_dll.Shipping\_Address\_Id\_\_c as Address\_Id\_\_c,Account\_\_dll.ShippingCity\_\_c as ShippingCity\_\_c,Account\_\_dll.ShippingCountry\_\_c as ShippingCountry\_\_c,Account\_\_dll.ShippingLatitude\_\_c as ShippingLatitude\_\_c,Account\_\_dll.ShippingLongitude\_\_c as ShippingLongitude\_\_c,Account\_\_dll.ShippingState\_\_c as ShippingState\_\_c,Account\_\_dll.ShippingStreet\_\_c as ShippingStreet\_\_c,Account\_\_dll.ShippingPostalCode\_\_c as ShippingPostalCode\_\_c FROM Account\_\_dll | Retail Execution Enhanced | Data Transform Name | Description | Target DLO | Query | | --- | --- | --- | --- | | Account Billing Address Data Transform | Transform Account's Billing Address into Account\_Billing\_Address\_dlo DLO | Account\_Billing\_Address\_dlo | SELECT Account\_\_dll.Billing\_Address\_Id\_\_c as Address\_Id\_\_c, Account\_\_dll.BillingCity\_\_c as BillingCity\_\_c, Account\_\_dll.BillingCountry\_\_c as BillingCountry\_\_c, Account\_\_dll.BillingLatitude\_\_c as BillingLatitude\_\_c, Account\_\_dll.BillingLongitude\_\_c as BillingLongitude\_\_c, Account\_\_dll.BillingState\_\_c as BillingState\_\_c, Account\_\_dll.BillingStreet\_\_c as BillingStreet\_\_c, Account\_\_dll.BillingPostalCode\_\_c as BillingPostalCode\_\_c FROM Account\_\_dll | | Account Shipping Address Data Transform | Transform Account's Shipping Address into Account\_Shipping\_Address\_dlo DLO | Account\_Shipping\_Address\_dlo | SELECT Account\_\_dll.Shipping\_Address\_Id\_\_c as Address\_Id\_\_c,Account\_\_dll.ShippingCity\_\_c as ShippingCity\_\_c,Account\_\_dll.ShippingCountry\_\_c as ShippingCountry\_\_c,Account\_\_dll.ShippingLatitude\_\_c as ShippingLatitude\_\_c,Account\_\_dll.ShippingLongitude\_\_c as ShippingLongitude\_\_c,Account\_\_dll.ShippingState\_\_c as ShippingState\_\_c,Account\_\_dll.ShippingStreet\_\_c as ShippingStreet\_\_c,Account\_\_dll.ShippingPostalCode\_\_c as ShippingPostalCode\_\_c FROM Account\_\_dll | | Account Task Participants Transformation | \- | Account\_Task\_Participants\_dlo | SELECT cgcloud\_Account\_Task\_c\_Home\_dIl.cgcloud\_Accountable\_c\_c as Participant \_c,"Accountable" as Activity\_Participant\_Role\_c, CONCAT( cgcloud\_Account\_Task\_c\_Home\_dIl.Id\_c, "\_Accountable") as Id\_c FROM cgoloud\_Account\_Task\_c\_Home\_dIl WHERE ISNOTNULL (cgcloud\_Account\_Task\_c\_Home\_dll.cgcloud\_Accountable\_c\_cUNION SELECT cgcloud\_Account\_Task\_c\_Home\_\_dIl.cgcloud\_Responsible\_c\_\_c as Participant\_c, "Responsible" as Activity\_Participant\_Role\_\_c, CONCAT( cgcloud\_Account\_Task\_c\_Home\_\_dIl.Id\_c, "\_Responsible") as Id\_\_c FROM egoloud\_Account\_Task\_c\_Home\_dII WHERE ISNOTNULL (cgcloud\_Account\_Task\_c\_Home\_dIl.cgcloud\_Responsible\_c\_c) | | Bill To Role Data Transform | Transform Account Extension's Bill To Role into Bill\_To\_Role\_dlo DLO | Bill\_To\_Role\_dlo | SELECT cgcloud\_Account\_Extension\_c\_\_dll.Bill\_To\_Role\_Id\_\_c as Account\_Role\_Id\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Account\_c\_\_c as Account\_\_c, "Bill To Role" as Account\_Role\_Type\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Bill\_To\_Role\_Valid\_From\_c\_\_c as Effective\_Start\_Date\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Bill\_To\_Role\_Valid\_Thru\_c\_\_c as Effective\_End\_Date\_\_c FROM cgcloud\_Account\_Extension\_c\_\_dll | | Broker Role Data Transform | Transform Account Extension's Broker Role into Broker\_Role\_dlo DLO | Broker\_Role\_dlo | SELECT cgcloud\_Account\_Extension\_c\_\_dll.Broker\_Role\_Id\_\_c as Account\_Role\_Id\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Account\_c\_\_c as Account\_\_c, "Broker Role" as Account\_Role\_Type\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Broker\_Role\_Valid\_From\_c\_\_c as Effective\_Start\_Date\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Broker\_Role\_Valid\_Thru\_c\_\_c as Effective\_End\_Date\_\_c FROM cgcloud\_Account\_Extension\_c\_\_dll | | Customer Role Data Transform | Transform Account Extension's Customer Role into Customer\_Role\_dlo DLO | Customer\_Role\_dlo | SELECT cgcloud\_Account\_Extension\_c\_\_dll.Customer\_Role\_Id\_\_c as Account\_Role\_Id\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Account\_c\_\_c as Account\_\_c, "Customer Role" as Account\_Role\_Type\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Customer\_Role\_Valid\_From\_c\_\_c as Effective\_Start\_Date\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Customer\_Role\_Valid\_Thru\_c\_\_c as Effective\_End\_Date\_\_c FROM cgcloud\_Account\_Extension\_c\_\_dll | | Delivery Role Data Transform | Transform Account Extension's Delivery Role into Delivery\_Role\_dlo DLO | Delivery\_Role\_dlo | SELECT cgcloud\_Account\_Extension\_c\_\_dll.Delivery\_Role\_Id\_\_c as Account\_Role\_Id\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Account\_c\_\_c as Account\_\_c, "Delivery Role" as Account\_Role\_Type\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Delivery\_Role\_Valid\_From\_c\_\_c as Effective\_Start\_Date\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Delivery\_Role\_Valid\_Thru\_c\_\_c as Effective\_End\_Date\_\_c FROM cgcloud\_Account\_Extension\_c\_\_dll | | Fund Role Data Transform | Transform Account Extension's Fund Role into Fund\_Role\_dlo DLO | Fund\_Role\_dlo | SELECT cgcloud\_Account\_Extension\_c\_\_dll.Fund\_Role\_Id\_\_c as Account\_Role\_Id\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Account\_c\_\_c as Account\_\_c, "Fund Role" as Account\_Role\_Type\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Fund\_Role\_Valid\_From\_c\_\_c as Effective\_Start\_Date\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Fund\_Role\_Valid\_Thru\_c\_\_c as Effective\_End\_Date\_\_c FROM cgcloud\_Account\_Extension\_c\_\_dll | | Order Billing Address Data Transform | Transform Order's Billing Address into Order\_Billing\_Address\_dlo DLO | Order\_Billing\_Address\_dlo | SELECT Order\_\_dll.Billing\_Address\_Id\_\_c as Address\_Id\_\_c, Order\_\_dll.BillingCity\_\_c as BillingCity\_\_c, Order\_\_dll.BillingCountry\_\_c as BillingCountry\_\_c, Order\_\_dll.BillingLatitude\_\_c as BillingLatitude\_\_c, Order\_\_dll.BillingLongitude\_\_c as BillingLongitude\_\_c, Order\_\_dll.BillingState\_\_c as BillingState\_\_c, Order\_\_dll.BillingStreet\_\_c as BillingStreet\_\_c, Order\_\_dll.BillingPostalCode\_\_c as BillingPostalCode\_\_c FROM Order\_\_dll | | Order Shipping Address Data Transform | Transform Order's Shipping Address into Order\_Shipping\_Address\_dlo DLO | Order\_Shipping\_Address\_dlo | SELECT Order\_\_dll.Id\_\_c as Address\_Id\_\_c, Order\_\_dll.ShippingCity\_\_c as ShippingCity\_\_c, Order\_\_dll.ShippingCountry\_\_c as ShippingCountry\_\_c, Order\_\_dll.ShippingLatitude\_\_c as ShippingLatitude\_\_c, Order\_\_dll.ShippingLongitude\_\_c as ShippingLongitude\_\_c, Order\_\_dll.ShippingState\_\_c as ShippingState\_\_c, Order\_\_dll.ShippingStreet\_\_c as ShippingStreet\_\_c, Order\_\_dll.ShippingPostalCode\_\_c as ShippingPostalCode\_\_c FROM Order\_\_dll | | Store Role Data Transform | Transform Account Extension's Store Role into Store\_Role\_dlo DLO | Store\_Role\_dlo | SELECT cgcloud\_Account\_Extension\_c\_\_dll.Store\_Role\_Id\_\_c as Account\_Role\_Id\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Account\_c\_\_c as Account\_\_c, "Store Role" as Account\_Role\_Type\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Store\_Role\_Valid\_From\_c\_\_c as Effective\_Start\_Date\_\_c, cgcloud\_Account\_Extension\_c\_\_dll.cgcloud\_Store\_Role\_Valid\_Thru\_c\_\_c as Effective\_End\_Date\_\_c FROM cgcloud\_Account\_Extension\_c\_\_dll | | Visit Location Transformation | \- | Visit\_Location\_dlo | SELECT Visit\_Home\_\_dll.CreatedDate\_\_c as Created\_Date\_\_c, Visit\_Home\_\_dIl.cgcloud\_Geolocation\_Latitude\_s\_\_c asLatitude\_\_c, Visit\_Home\_dIl.cgcloud\_Geolocation\_Longitude\_s\_c as Longitude\_\_c, Visit\_Home\_dIl.LastModifiedDate\_\_c as Last\_Modified\_Date\_\_c, Visit\_Home\_\_dII.Locationld\_\_c as Location\_Id\_\_c, Visit\_Home\_\_dIl.cgcloud\_Location\_Status\_c\_\_c asLocation\_Status\_c, Visit\_Home\_\_dII.Name\_\_c as Name\_\_c FROM Visit\_Home\_\_dII | | Account Receivable Data Transform | Account\_Billing\_Address\_dlo, and Account\_Receivable\_Credit\_Memo\_dlo | Batch | \- | | Job Definition Template Data Tranformation | Job\_Definition\_Template\_dlo | Batch | \- | | POS Template Data Transform | cgcloud\_\_POS\_POS\_Template\_\_c | Batch | \- | | Promotion Account Data Transform | Promotion\_Account\_dlo | Batch | \- | | Tactic Type Data Transform | Tactic\_Type\_dlo | Batch | \- | | Visit Job Data Type Data Transformation | Visit\_Job\_dlo | Batch | \- |