sqlContext.registerFunction('day', lambda x: x.day)
sqlContext.registerDataFrameAsTable(df, 'df')
sqlContext.sql('SELECT *, day(date_time) as day FROM df')
PySpark добавляет столбец в DataFrame из столбца TimeStampType