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 f462e67f36 [INLONG-8997][Sort] Keep the logic the same of mysql with
flink v1.13 in end to end test
add a3f8102de2 [INLONG-8695][Sort] Add Pulsar connector based on flink
1.15 (#9005)
No new revisions were added by this update.
Summary of changes:
.../src/main/assemblies/sort-connectors-v1.15.xml | 8 +
.../sort-flink-v1.15/sort-connectors/pom.xml | 1 +
.../sort-connectors/pulsar/pom.xml | 277 ++++++++++++++++++++
.../inlong/sort/pulsar/PulsarTableFactory.java | 216 ++++++++++++++++
.../inlong/sort/pulsar/PulsarTableOptionUtils.java | 248 ++++++++++++++++++
.../inlong/sort/pulsar/PulsarTableOptions.java | 285 +++++++++++++++++++++
.../sort/pulsar/PulsarTableValidationUtils.java | 152 +++++++++++
.../sort/pulsar/table/PulsarReadableMetadata.java | 145 +++++++++++
.../sort/pulsar/table/PulsarRowDataConverter.java | 132 ++++++++++
.../table/PulsarTableDeserializationSchema.java | 109 ++++++++
.../PulsarTableDeserializationSchemaFactory.java | 216 ++++++++++++++++
.../sort/pulsar/table/PulsarTableSource.java | 226 ++++++++++++++++
.../org.apache.flink.table.factories.Factory | 2 +-
licenses/inlong-sort-connectors/LICENSE | 13 +
14 files changed, 2029 insertions(+), 1 deletion(-)
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/pom.xml
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/PulsarTableFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/PulsarTableOptionUtils.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/PulsarTableOptions.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/PulsarTableValidationUtils.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarReadableMetadata.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarRowDataConverter.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableDeserializationSchema.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableDeserializationSchemaFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableSource.java
copy inlong-sort/{sort-formats/format-inlongmsg-base/src/test =>
sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main}/resources/META-INF/services/org.apache.flink.table.factories.Factory
(94%)
