Filtern von Datensätzen der Streaming-Datentransformation

Verwenden Sie die WHERE-Klausel in der SQL-Anweisung für Streaming-Datentransformationen, um einzuschränken, welche Quellobjektdatensätze die Streaming-Datentransformation liest und verarbeitet.

Angenommen, Sie möchten beispielsweise eine Streaming-Datentransformation erstellen, die nur dann aus dem Objekt "CRMContacts" gelesen und verarbeitet wird, wenn das Feld "WorkPhone" einen Nicht-NULL-Wert aufweist.

In dieser SQL-Anweisung filtert die Klausel WHERE ISNOTNULL(object.field) Datensätze heraus, die keine Telefonnummer enthalten.

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 <> ""

Wenn ein Datensatz im Quellobjekt so aktualisiert wird, dass er nicht mehr mit dem WHERE übereinstimmt, wird der Datensatz aus dem Zielobjekt gelöscht.