streamsets 丟踢無關數據

對於不須要的數據,streamsets 能夠方便的設置丟踢,咱們能夠經過定義require 字段或者前置條件進行配置html

require(必須字段)

必須字段是必須存在一條record 中的,對於不存在的,系統根據配置的error 處理規則進行處理,require 字段
能夠在processor executor destinnation 階段進行定義ide

前置條件

前置條件是用來限制record 必須知足處理的條件,前置條件能夠定義在processor executor destination 階段,同
時能夠好似哦要哪一個functions pipeline 常量以及運行時屬性
參考:ui

${record:value('/COUNTRY')=='UD'}

參考資料

https://streamsets.com/documentation/datacollector/latest/help/datacollector/UserGuide/Pipeline_Design/DroppingUnwantedRecords.html#concept_ejl_lpy_btcode

相關文章
相關標籤/搜索