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