+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1+1
s = df[data].where(df[data].groupby(df[data].ne(df[data].shift()).cumsum()).transform
tsRDD.map(lambda x:(x,1)).groupByKey()[('abc', <pyspark.resultiterable.ResultIterable object at 0xb0e8242cpyspark.resultiterable.ResultIterable object at 0xb0e824ac>)]tsRDD.map(lambda x:(x,