This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from bea741c97 [INLONG-4946][Manager] Improve the dependency for the
manager module (#4947)
add 4a9b94209 [INLONG-4890][Sort] Support TubeMQ connector (#4891)
No new revisions were added by this update.
Summary of changes:
.../src/main/assemblies/sort-connectors.xml | 8 +
inlong-sort/sort-connectors/pom.xml | 1 +
inlong-sort/sort-connectors/tubemq/pom.xml | 86 +++++
.../inlong/sort/tubemq/FlinkTubeMQConsumer.java | 230 ++++++------
.../table/DynamicTubeMQDeserializationSchema.java} | 93 ++---
.../tubemq/table/TubeMQDynamicTableFactory.java | 180 +++++++++
.../inlong/sort/tubemq/table/TubeMQOptions.java | 418 +++++++++++++++++++++
.../sort/tubemq/table/TubeMQTableSource.java | 338 +++++++++++++++++
.../org.apache.flink.table.factories.Factory | 2 +-
inlong-sort/sort-core/pom.xml | 6 +
10 files changed, 1183 insertions(+), 179 deletions(-)
create mode 100644 inlong-sort/sort-connectors/tubemq/pom.xml
copy
inlong-tubemq/tubemq-connectors/tubemq-connector-flink/src/main/java/org/apache/flink/connectors/tubemq/TubemqSourceFunction.java
=>
inlong-sort/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQConsumer.java
(60%)
copy
inlong-sort/{sort-formats/format-inlongmsg-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/InLongMsgDeserializationSchema.java
=>
sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/DynamicTubeMQDeserializationSchema.java}
(57%)
create mode 100644
inlong-sort/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java
create mode 100644
inlong-sort/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQOptions.java
create mode 100644
inlong-sort/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQTableSource.java
copy inlong-sort/sort-connectors/{jdbc =>
tubemq}/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(92%)
