[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Counting DataSet in DataFlow


I would like to a way to count a dataset to check if it is empty or not.. But .count() throw an execution and I do not want to do separe job execution plan, as hthis will trigger multiple reading..
I would like to have something like..

Source -> map -> count -> if 0 -> do someting 
                                           if not -> do something

More concrete i would like to check if one of my dataset is empty before doing a cross operation..