Pyspark - форматирование дат с использованием блока Exception - PullRequest
0 голосов
/ 07 февраля 2019

Я пытаюсь отформатировать столбец даты в моем массиве данных Pyspark, но блок Exception выдает ошибку.Я исследовал это и не похоже, что Pyspark в настоящее время поддерживает обработку исключений.Как еще я мог бы достичь этого, не прерывая программу, когда она встречает исключение?

try: df['TIME'] = df.select(date_format('TIME', '%H:%M:%S.%f'))
except ValueError:  df['TIME'] = df.select(date_format('TIME', '%H:%S.%f'))
...