Ответ 1
Сначала конвертируйте java.util.Date в java.sql.Date. Затем запустите свой sql с данными java.sql.Date. Пример кода:
java.util.Date utilDate = new java.util.Date();
java.sql.Date sqlDate = new java.sql.Date(utilDate.getTime());
Я хочу написать RDD
в MYSQL
, который RDD
содержит java.util.Date
тип.
rdd.map(f=> FeatureData(
f.get("name").toString,
f.get("value").toString.toDouble,
f.get("time").asInstanceOf[Date],
f.get("period").toString))
.toDF()
В этом RDD
ключ типа значения time
также java.util.Date
, и он просто получает ошибку
[See nested exception: java.lang.UnsupportedOperationException: Schema for type java.util.Date is not supported
Сначала конвертируйте java.util.Date в java.sql.Date. Затем запустите свой sql с данными java.sql.Date. Пример кода:
java.util.Date utilDate = new java.util.Date();
java.sql.Date sqlDate = new java.sql.Date(utilDate.getTime());