You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by wa...@apache.org on 2022/03/15 11:10:21 UTC

[hudi] branch master updated (d40adfa -> 3b59b76)

This is an automated email from the ASF dual-hosted git repository.

wangxianghu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.


    from d40adfa  [HUDI-3620] Adding spark3.2.0 profile (#5038)
     add 3b59b76  [HUDI-3547] Introduce MaxwellSourcePostProcessor to extract data from Maxwell json string (#4987)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/hudi/common/util/DateTimeUtils.java |  17 ++
 .../MaxwellJsonKafkaSourcePostProcessor.java       | 190 +++++++++++++++++++++
 .../processor/maxwell/PreCombineFieldType.java     |  32 ++--
 .../sources/TestJsonKafkaSourcePostProcessor.java  | 130 ++++++++++++++
 4 files changed, 354 insertions(+), 15 deletions(-)
 create mode 100644 hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/maxwell/MaxwellJsonKafkaSourcePostProcessor.java
 copy hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/HiveSyncMode.java => hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/maxwell/PreCombineFieldType.java (67%)