From 982ac4d0a026c9743736ccefbc39279b480193a0 Mon Sep 17 00:00:00 2001 From: xiaoyou201 Date: Wed, 26 Jun 2024 12:59:19 +0800 Subject: [PATCH] [INLONG-10358][Sort] Add reference and LICENSE --- .../org/apache/inlong/sort/pulsar/source/PulsarSource.java | 2 ++ .../inlong/sort/pulsar/source/PulsarSourceBuilder.java | 2 ++ .../sort/pulsar/source/PulsarSourceReaderFactory.java | 2 ++ .../pulsar/source/reader/PulsarOrderedSourceReader.java | 1 + .../sort/pulsar/source/reader/PulsarSourceReaderBase.java | 2 ++ .../pulsar/source/reader/PulsarUnorderedSourceReader.java | 1 + licenses/inlong-sort-connectors/LICENSE | 6 ++++++ 7 files changed, 16 insertions(+) diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSource.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSource.java index c761a881650..b7b608ec826 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSource.java +++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSource.java @@ -61,6 +61,8 @@ *

See {@link PulsarSourceBuilder} for more details. * * @param The output type of the source. + * copy from {@link org.apache.flink.connector.pulsar.source.PulsarSource} + * not modified */ @PublicEvolving public final class PulsarSource diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java index ad765231e6c..d8c05ce152f 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java +++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java @@ -111,6 +111,8 @@ * } * * @param The output type of the source. + * copy from {@link org.apache.flink.connector.pulsar.source.PulsarSourceBuilder} + * not modified */ @PublicEvolving public final class PulsarSourceBuilder { diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceReaderFactory.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceReaderFactory.java index b3a78628334..bbc42c149f4 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceReaderFactory.java +++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceReaderFactory.java @@ -50,6 +50,8 @@ *

  • Failover, Exclusive: We would create {@link PulsarOrderedSourceReader}. *
  • Shared, Key_Shared: We would create {@link PulsarUnorderedSourceReader}. * + * copy from {@link org.apache.flink.connector.pulsar.source.reader.PulsarSourceReaderFactory} + * not modified */ @Internal public final class PulsarSourceReaderFactory { diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarOrderedSourceReader.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarOrderedSourceReader.java index 6e90840e507..f535082ea28 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarOrderedSourceReader.java +++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarOrderedSourceReader.java @@ -57,6 +57,7 @@ /** * The source reader for pulsar subscription Failover and Exclusive, which consumes the ordered * messages. + * copy from {@link org.apache.flink.connector.pulsar.source.reader.source.PulsarUnorderedSourceReader} */ @Internal public class PulsarOrderedSourceReader extends PulsarSourceReaderBase { diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReaderBase.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReaderBase.java index d454038df27..f7e6bafc1da 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReaderBase.java +++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReaderBase.java @@ -34,6 +34,8 @@ * The common pulsar source reader for both ordered & unordered message consuming. * * @param The output message type for flink. + * copy from {@link org.apache.flink.connector.pulsar.source.reader.source.PulsarUnorderedSourceReader} + * not modified */ abstract class PulsarSourceReaderBase extends diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarUnorderedSourceReader.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarUnorderedSourceReader.java index cca709e9b68..2ccf74fe3aa 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarUnorderedSourceReader.java +++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarUnorderedSourceReader.java @@ -52,6 +52,7 @@ /** * The source reader for pulsar subscription Shared and Key_Shared, which consumes the unordered * messages. + * copy from {@link org.apache.flink.connector.pulsar.source.reader.source.PulsarUnorderedSourceReader} */ @Internal public class PulsarUnorderedSourceReader extends PulsarSourceReaderBase { diff --git a/licenses/inlong-sort-connectors/LICENSE b/licenses/inlong-sort-connectors/LICENSE index b33808eb954..81d60c723ca 100644 --- a/licenses/inlong-sort-connectors/LICENSE +++ b/licenses/inlong-sort-connectors/LICENSE @@ -804,6 +804,12 @@ inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/PulsarTableOptions.java inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/PulsarTableOptionUtils.java inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/PulsarTableValidationUtils.java + inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSource.java + inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java + inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceReaderFactory.java + inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarOrderedSourceReader.java + inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReaderBase.java + inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarUnorderedSourceReader.java Source : flink-connector-pulsar 4.0-SNAPSHOT (Please note that the software have been modified.) License : https://github.com/apache/flink-connector-pulsar/blob/main/LICENSE