Я работаю над проектом, в котором использую очень новую для меня библиотеку, хотя я использовал ее в других проектах без каких-либо проблем.
org.joda.time.DateTime
Поэтому я работаю с Scala и запускаю проект как задание на Databricks.
scalaVersion := "2.11.12"
Код, из которого исходит исключение - согласно моему расследованию до сих пор ^^ - следующий:
var lastEndTime = config.getState("some parameters")
val timespanStart: Long = lastEndTime // last query ending time
var timespanEnd: Long = (System.currentTimeMillis / 1000) - (60*840) // 14 hours ago
val start = new DateTime(timespanStart * 1000)
val end = new DateTime(timespanEnd * 1000)
val date = DateTime.now()
Где функция getState() возвращает 1483228800 в качестве значения типа Long.
EDIT: я использую даты начала и окончания в фильтрации при создании фрейма данных. Я сравниваю столбцы (тип timespan) с этими значениями!
val df2= df
.where(col("column_name").isNotNull)
.where(col("column_name") > start &&
col("column_name") <= end)
Ошибка, которую я получаю:
ОШИБКА Uncaught throwable from user code: java.lang.RuntimeException: неподдерживаемый литеральный тип класса org.joda.time.DateTime 2017-01-01T00:00:00.000Z
Я не уверен, что на самом деле понимаю, как и почему это ошибка, поэтому любая помощь более чем приветствуется! Заранее большое спасибо!!