cdmikechen commented on code in PR #3391:
URL: https://github.com/apache/hudi/pull/3391#discussion_r879378219
##########
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieHiveUtils.java:
##########
@@ -146,4 +154,74 @@ public static List<String>
getIncrementalTableNames(JobContext job) {
public static boolean isIncrementalUseDatabase(Configuration conf) {
return conf.getBoolean(HOODIE_INCREMENTAL_USE_DATABASE, false);
}
+
+ public static boolean SUPPORT_TIMESTAMP_WRITEABLE_V2;
+ private static Class timestampClass = null;
+ private static Method setTimeInMillis = null;
+ private static Constructor timestampWriteableV2constructor = null;
+
+ public static boolean SUPPORT_DATE_WRITEABLE_V2;
+ private static Constructor dateWriteableV2constructor = null;
+
+ static {
+ // timestamp
+ try {
+ timestampClass =
Class.forName("org.apache.hadoop.hive.common.type.Timestamp");
+ setTimeInMillis = timestampClass.getDeclaredMethod("setTimeInMillis",
long.class);
+ Class twV2Class =
Class.forName("org.apache.hadoop.hive.serde2.io.TimestampWritableV2");
+ timestampWriteableV2constructor =
twV2Class.getConstructor(timestampClass);
Review Comment:
@xiarixiaoyao
My mistake, I will modify it right now
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
