[INLONG-10682][Sort] Add LICENSE and reference.

apache · Jul 22, 2024 · a3024f3 · a3024f3
1 parent e4b507f
commit a3024f3
Show file tree

Hide file tree

Showing 4 changed files with 6 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
@@ -63,6 +63,7 @@
  * <p>See {@link PulsarSourceBuilder} for more details.
  *
  * @param <OUT> The output type of the source.
+ * Modify from  {@link org.apache.flink.connector.pulsar.source.PulsarSource}
  */
 @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
@@ -120,6 +120,7 @@
  * }</pre>
  *
  * @param <OUT> The output type of the source.
+ * Modify from  {@link org.apache.flink.connector.pulsar.source.PulsarSourceBuilder}
  */
 @PublicEvolving
 public final class PulsarSourceBuilder<OUT> {

diff --git a/.../pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReader.java b/.../pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReader.java
@@ -71,6 +71,7 @@
  * messages.
  *
  * @param <OUT> The output message type for flink.
+ * Modify from  {@link org.apache.flink.connector.pulsar.source.reader.PulsarSourceReader}
  */
 @Internal
 public class PulsarSourceReader<OUT>

diff --git a/licenses/inlong-sort-connectors/LICENSE b/licenses/inlong-sort-connectors/LICENSE
@@ -856,6 +856,9 @@
        inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/source/PulsarTableDeserializationSchema.java
        inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/source/PulsarTableDeserializationSchemaFactory.java
        inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/source/PulsarTableSource.java
+       inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarTableSource.java
+       inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java
+       inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReader.java
   Source  : org.apache.flink:flink-connector-pulsar:4.1.0-1.18 (Please note that the software have been modified.)
   License : https://github.com/apache/flink-connector-pulsar/blob/main/LICENSE