Search
 
SCRIPT & CODE EXAMPLE
 
CODE EXAMPLE FOR PYTHON

forward fill in pyspark

cols = ['latitude', 'longitude']
df_new = df.select([ c for c in df.columns if c not in cols ] + [ coalesce(last(c,True).over(w1), first(c,True).over(w2)).alias(c) for c in cols ])
Source by stackoverflow.com #
 
PREVIOUS NEXT
Tagged: #fill #pyspark
ADD COMMENT
Topic
Name
4+6 =