Apache Beam basically a data processing platform. Data processing can be either for analytics purpose or it can be ETL (Extract, Transfer, Load). Apache beam doesn't reply on any one execution ...
import pandas as pd df = pd.DataFrame(dict(A=[1,1,2,2,3], B=[4,4,5,5,6])) def f(x): return x['A'] < 'taco' df.groupby('A').apply(f) Results in three exceptions stacked on top of each other. See below.
Some results have been hidden because they may be inaccessible to you
Show inaccessible results
Feedback