[INLONG-10358][Sort] Add reference and LICENSE

XiaoYou201 · Jun 26, 2024 · 982ac4d · 982ac4d
1 parent 2246ea8
commit 982ac4d
Show file tree

Hide file tree

Showing 7 changed files with 16 additions and 0 deletions.
diff --git a/...rt-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSource.java b/...rt-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSource.java
@@ -61,6 +61,8 @@
  * <p>See {@link PulsarSourceBuilder} for more details.
  *
  * @param <OUT> The output type of the source.
+ * copy from {@link org.apache.flink.connector.pulsar.source.PulsarSource}
+ * not modified
  */
 @PublicEvolving
 public final class PulsarSource<OUT>

diff --git a/...ectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java b/...ectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java
@@ -111,6 +111,8 @@
  * }</pre>
  *
  * @param <OUT> The output type of the source.
+ * copy from {@link org.apache.flink.connector.pulsar.source.PulsarSourceBuilder}
+ * not modified
  */
 @PublicEvolving
 public final class PulsarSourceBuilder<OUT> {

diff --git a/.../pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceReaderFactory.java b/.../pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceReaderFactory.java
@@ -50,6 +50,8 @@
  * <li>Failover, Exclusive: We would create {@link PulsarOrderedSourceReader}.
  * <li>Shared, Key_Shared: We would create {@link PulsarUnorderedSourceReader}.
  * </ol>
+ * copy from {@link org.apache.flink.connector.pulsar.source.reader.PulsarSourceReaderFactory}
+ * not modified
  */
 @Internal
 public final class PulsarSourceReaderFactory {

diff --git a/.../src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarOrderedSourceReader.java b/.../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<OUT> extends PulsarSourceReaderBase<OUT> {

diff --git a/...sar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReaderBase.java b/...sar/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 <OUT> The output message type for flink.
+ * copy from {@link org.apache.flink.connector.pulsar.source.reader.source.PulsarUnorderedSourceReader}
+ * not modified
  */
 abstract class PulsarSourceReaderBase<OUT>
  extends

diff --git a/...rc/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarUnorderedSourceReader.java b/...rc/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<OUT> extends PulsarSourceReaderBase<OUT> {

diff --git 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