Filter Streaming Data Transform Records

Use the WHERE clause in the streaming data transform SQL statement to limit which source object records the streaming data transform reads and processes.

For example, suppose you want to create a streaming data transform that reads and processes from the CRMContacts object only when the WorkPhone field has a non- NULL value.

In this SQL statement, the WHERE ISNOTNULL(object.field) clause filters out records that don’t contain a work phone number.

SELECT CONCAT(CRMContacts.CustomerId, "_1") as PhoneId,
    CRMContacts.CustomerId as CustomerId, 
    CRMContacts.MobilePhone as PhoneNumber,
    "Mobile" as PhoneType
FROM CRMContacts
WHERE ISNOTNULL(CRMContacts.WorkPhone) AND CRMContacts.WorkPhone <> ""

If a record in the source object is updated so that it no longer matches the WHERE filter, the record is deleted from the target object.