@@ -229,7 +229,7 @@ internal class ArrowWriterImpl(
229
229
is DateDayVector ->
230
230
column.convertToLocalDate()
231
231
.forEachIndexed { i, value ->
232
- value?.also { vector.set(i, value.toJavaLocalDate().toEpochDay().toInt ()) }
232
+ value?.also { vector.set(i, value.toEpochDays ()) }
233
233
? : vector.setNull(i)
234
234
}
235
235
@@ -243,29 +243,29 @@ internal class ArrowWriterImpl(
243
243
is TimeNanoVector ->
244
244
column.convertToLocalTime()
245
245
.forEachIndexed { i, value ->
246
- value?.also { vector.set(i, value.toJavaLocalTime().toNanoOfDay ()) }
246
+ value?.also { vector.set(i, value.toNanosecondOfDay ()) }
247
247
? : vector.setNull(i)
248
248
}
249
249
250
250
is TimeMicroVector ->
251
251
column.convertToLocalTime()
252
252
.forEachIndexed { i, value ->
253
- value?.also { vector.set(i, value.toJavaLocalTime().toNanoOfDay () / 1000 ) }
253
+ value?.also { vector.set(i, value.toNanosecondOfDay () / 1000 ) }
254
254
? : vector.setNull(i)
255
255
}
256
256
257
257
is TimeMilliVector ->
258
258
column.convertToLocalTime()
259
259
.forEachIndexed { i, value ->
260
- value?.also { vector.set(i, (value.toJavaLocalTime().toNanoOfDay () / 1000 / 1000 ).toInt()) }
260
+ value?.also { vector.set(i, (value.toNanosecondOfDay () / 1000 / 1000 ).toInt()) }
261
261
? : vector.setNull(i)
262
262
}
263
263
264
264
is TimeSecVector ->
265
265
column.convertToLocalTime()
266
266
.forEachIndexed { i, value ->
267
267
value?.also {
268
- vector.set(i, (value.toJavaLocalTime().toNanoOfDay () / 1000 / 1000 / 1000 ).toInt())
268
+ vector.set(i, (value.toNanosecondOfDay () / 1000 / 1000 / 1000 ).toInt())
269
269
} ? : vector.setNull(i)
270
270
}
271
271
0 commit comments