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%)
