df_y = sqlContext.read.json('/user/test.json')
udf_dt = func.udf(lambda x: datetime.strptime(x, '%Y%m%d%H%M%S'),
    TimestampType())
Получите отдельные элементы каждой группы по другому полю в кадре данных Spark 1.6.