Skip to content

Commit d5800f9

Browse files
committed
Fix OrcColumnVector v1.2
1 parent 248b9a5 commit d5800f9

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sql/core/v1.2/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnVector.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import org.apache.orc.storage.ql.exec.vector.*;
2323

2424
import org.apache.spark.sql.catalyst.util.DateTimeUtils;
25+
import org.apache.spark.sql.catalyst.util.RebaseDateTime;
2526
import org.apache.spark.sql.types.DataType;
2627
import org.apache.spark.sql.types.DateType;
2728
import org.apache.spark.sql.types.Decimal;
@@ -140,7 +141,7 @@ public short getShort(int rowId) {
140141
public int getInt(int rowId) {
141142
int value = (int) longData.vector[getRowIndex(rowId)];
142143
if (isDate) {
143-
return DateTimeUtils.rebaseJulianToGregorianDays(value);
144+
return RebaseDateTime.rebaseJulianToGregorianDays(value);
144145
} else {
145146
return value;
146147
}

0 commit comments

Comments
 (0)