У меня есть датафрейм, и я должен реализовать приведенный ниже лог c в pyspark
if first.item then do; cum_count = amt1; end; else do; cum_count = cum_count + amt1; end;