This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from fcd0666 [INLONG-2707][Manager] Table name and field type was
inconsistent in SQL and XML file (#2708)
add efe96a7 [INLONG-2625][Sort] Support extracting data time in
deserialization (#2627)
No new revisions were added by this update.
Summary of changes:
.../inlong/sort/configuration/Configuration.java | 6 +
.../inlong/sort/configuration/Constants.java | 20 +++
.../{FieldInfo.java => BuiltInFieldInfo.java} | 56 ++++-----
.../inlong/sort/util/DefaultValueStrategy.java | 75 +++++++++++
.../deserialization/DeserializationSchema.java | 2 +-
.../deserialization/MultiTenancyDeserializer.java | 2 +-
.../MultiTenancyInLongMsgMixedDeserializer.java | 3 +-
.../transformation/FieldMappingTransformer.java | 137 ++++++++++++---------
.../org/apache/inlong/sort/util/CommonUtils.java | 15 +++
.../FieldMappingTransformerTest.java | 25 ++--
.../inlong/sort/singletenant/flink/Entrance.java | 18 ++-
.../flink/deserialization/CallbackCollector.java | 6 +-
.../deserialization/DeserializationFunction.java | 11 +-
.../deserialization/FieldMappingTransformer.java | 101 +++++++++++++++
.../DeserializationFunctionTest.java | 7 +-
.../FieldMappingTransformerTest.java | 66 ++++++++++
16 files changed, 434 insertions(+), 116 deletions(-)
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/{FieldInfo.java
=> BuiltInFieldInfo.java} (57%)
create mode 100644
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/DefaultValueStrategy.java
copy inlong-sort/{sort-core/src/main/java/org/apache/inlong/sort =>
sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant}/flink/deserialization/CallbackCollector.java
(95%)
create mode 100644
inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/deserialization/FieldMappingTransformer.java
create mode 100644
inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/deserialization/FieldMappingTransformerTest.java
