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 95fbaab22 [INLONG-5040][Sort] Add Apache Doris extract node for Sort
(#5502)
add be75dd022 [INLONG-5564][Sort] Support read Pulsar source without
adminUrl (#5568)
No new revisions were added by this update.
Summary of changes:
.../protocol/node/extract/PulsarExtractNode.java | 9 +-
.../pulsar/table/PulsarDynamicTableFactory.java | 13 +-
.../pulsar/table/PulsarDynamicTableSource.java | 103 ++-
.../table/UpsertPulsarDynamicTableFactory.java | 6 +-
.../pulsar/withoutadmin/FlinkPulsarSource.java | 928 +++++++++++++++++++++
.../sort/pulsar/withoutadmin/PulsarFetcher.java | 710 ++++++++++++++++
.../pulsar/withoutadmin/PulsarMetadataReader.java | 251 ++++++
.../sort/pulsar/withoutadmin/ReaderThread.java | 222 +++++
licenses/inlong-sort-connectors/LICENSE | 4 +
9 files changed, 2203 insertions(+), 43 deletions(-)
create mode 100644
inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/withoutadmin/FlinkPulsarSource.java
create mode 100644
inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/withoutadmin/PulsarFetcher.java
create mode 100644
inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/withoutadmin/PulsarMetadataReader.java
create mode 100644
inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/withoutadmin/ReaderThread.java
