Dqchecks on beam

[Sofia’s World]

Hi all
 Are there any facilities to do dqchecks on apache beam?
Got few jobs that download data from web..do some filters transformation
and aggregation..
Want to introduce dqchecks so Job fails if certain conditions are not met
eg number of outputs....
Is that achievable in beam?
Thanks. Marco