diff --git a/pulsar-paimon-sink/.idea/.gitignore b/pulsar-paimon-sink/.idea/.gitignore new file mode 100644 index 0000000..13566b8 --- /dev/null +++ b/pulsar-paimon-sink/.idea/.gitignore @@ -0,0 +1,8 @@ +# Default ignored files +/shelf/ +/workspace.xml +# Editor-based HTTP Client requests +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/pulsar-paimon-sink/.idea/checkstyle-idea.xml b/pulsar-paimon-sink/.idea/checkstyle-idea.xml new file mode 100644 index 0000000..fa3e25c --- /dev/null +++ b/pulsar-paimon-sink/.idea/checkstyle-idea.xml @@ -0,0 +1,15 @@ + + + + 10.18.2 + JavaOnly + + + \ No newline at end of file diff --git a/pulsar-paimon-sink/.idea/compiler.xml b/pulsar-paimon-sink/.idea/compiler.xml new file mode 100644 index 0000000..a8487d2 --- /dev/null +++ b/pulsar-paimon-sink/.idea/compiler.xml @@ -0,0 +1,14 @@ + + + + + + + + + + + + + + \ No newline at end of file diff --git a/pulsar-paimon-sink/.idea/encodings.xml b/pulsar-paimon-sink/.idea/encodings.xml new file mode 100644 index 0000000..aa00ffa --- /dev/null +++ b/pulsar-paimon-sink/.idea/encodings.xml @@ -0,0 +1,7 @@ + + + + + + + \ No newline at end of file diff --git a/pulsar-paimon-sink/.idea/jarRepositories.xml b/pulsar-paimon-sink/.idea/jarRepositories.xml new file mode 100644 index 0000000..45bb057 --- /dev/null +++ b/pulsar-paimon-sink/.idea/jarRepositories.xml @@ -0,0 +1,25 @@ + + + + + + + + + + + + + \ No newline at end of file diff --git a/pulsar-paimon-sink/.idea/misc.xml b/pulsar-paimon-sink/.idea/misc.xml new file mode 100644 index 0000000..0abcc97 --- /dev/null +++ b/pulsar-paimon-sink/.idea/misc.xml @@ -0,0 +1,12 @@ + + + + + + + + \ No newline at end of file diff --git a/pulsar-paimon-sink/.idea/uiDesigner.xml b/pulsar-paimon-sink/.idea/uiDesigner.xml new file mode 100644 index 0000000..2b63946 --- /dev/null +++ b/pulsar-paimon-sink/.idea/uiDesigner.xml @@ -0,0 +1,124 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/pulsar-paimon-sink/dependency-reduced-pom.xml b/pulsar-paimon-sink/dependency-reduced-pom.xml new file mode 100644 index 0000000..02b4a2c --- /dev/null +++ b/pulsar-paimon-sink/dependency-reduced-pom.xml @@ -0,0 +1,64 @@ + + + + apache + org.apache + 18 + ../pom.xml/pom.xml + + 4.0.0 + org.apache.pulsar.ecosystem + pulsar-io-paimon + Pulsar Ecosystem :: IO Connector :: Lake House + 2.11.0-SNAPSHOT + It is a lakehouse connector streaming convert data between lakehouse and Apache Pulsar. + + + + maven-shade-plugin + 3.2.4 + + + package + + shade + + + + + *:* + + META-INF/*.SF + META-INF/*.DSA + META-INF/*.RSA + + + + + + com.example.PulsarJsonProducer + + + + + + + + + + + org.projectlombok + lombok + 1.18.30 + provided + + + + ${java.version} + 17 + ${java.version} + 3.0.7 + 0.9.0 + true + + diff --git a/pulsar-paimon-sink/pom.xml b/pulsar-paimon-sink/pom.xml new file mode 100644 index 0000000..66aded3 --- /dev/null +++ b/pulsar-paimon-sink/pom.xml @@ -0,0 +1,128 @@ + + + + + org.apache + apache + 18 + + + 4.0.0 + + org.apache.pulsar.ecosystem + pulsar-io-paimon + 2.11.0-SNAPSHOT + Pulsar Ecosystem :: IO Connector :: Lake House + It is a lakehouse connector streaming convert data between lakehouse and Apache Pulsar. + + + 17 + 3.0.7 + 0.9.0 + ${java.version} + ${java.version} + true + + + + + + + com.fasterxml.jackson.core + jackson-databind + 2.15.0 + + + org.apache.hadoop + hadoop-client + 3.2.1 + + + + org.apache.pulsar + pulsar-io-core + ${pulsar.version} + + + + + org.apache.paimon + paimon-core + ${paimon.version} + + + + + org.apache.logging.log4j + log4j-slf4j-impl + 2.17.2 + + + + + org.projectlombok + lombok + 1.18.30 + provided + + + + + + + + + org.apache.maven.plugins + maven-shade-plugin + 3.2.4 + + + package + + shade + + + + + *:* + + META-INF/*.SF + META-INF/*.DSA + META-INF/*.RSA + + + + + + com.example.PulsarJsonProducer + + + + + + + + + + diff --git a/pulsar-paimon-sink/pulsar-paimon-sink.iml b/pulsar-paimon-sink/pulsar-paimon-sink.iml new file mode 100644 index 0000000..9e3449c --- /dev/null +++ b/pulsar-paimon-sink/pulsar-paimon-sink.iml @@ -0,0 +1,6 @@ + + + + + \ No newline at end of file diff --git a/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/CreateCatalog.java b/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/CreateCatalog.java new file mode 100644 index 0000000..320cdeb --- /dev/null +++ b/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/CreateCatalog.java @@ -0,0 +1,19 @@ +package org.apache.pulsar.ecosystem.io.paimon.sink; + +import org.apache.paimon.catalog.Catalog; +import org.apache.paimon.catalog.CatalogContext; +import org.apache.paimon.catalog.CatalogFactory; +import org.apache.paimon.fs.Path; + +public class CreateCatalog { + + /** + * Creates a Filesystem Catalog. + * + * @return the created Catalog + */ + public static Catalog createFilesystemCatalog() { + CatalogContext context = CatalogContext.create(new Path("/pulsar/data")); + return CatalogFactory.createCatalog(context); + } +} \ No newline at end of file diff --git a/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/GetTable.java b/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/GetTable.java new file mode 100644 index 0000000..e9fd2bd --- /dev/null +++ b/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/GetTable.java @@ -0,0 +1,44 @@ +package org.apache.pulsar.ecosystem.io.paimon.sink; + +import org.apache.paimon.catalog.Catalog; +import org.apache.paimon.catalog.Identifier; +import org.apache.paimon.schema.Schema; +import org.apache.paimon.table.Table; +import org.apache.paimon.types.DataTypes; + +public class GetTable { + public static Table getTable() { + Identifier identifier = Identifier.create("pulsar_paimon", "message_trace"); + try { + Catalog catalog = CreateCatalog.createFilesystemCatalog(); + org.apache.paimon.schema.Schema.Builder schemaBuilder = org.apache.paimon.schema.Schema.newBuilder(); + schemaBuilder.primaryKey("f0", "f1", "f2", "f3", "f4", "f5", "f6", "f7", "f8", "f9"); + schemaBuilder.partitionKeys("f0"); + + schemaBuilder.column("f0", DataTypes.STRING()); + schemaBuilder.column("f1", DataTypes.STRING()); + schemaBuilder.column("f2", DataTypes.STRING()); + schemaBuilder.column("f3", DataTypes.STRING()); + schemaBuilder.column("f4", DataTypes.STRING()); + schemaBuilder.column("f5", DataTypes.STRING()); + schemaBuilder.column("f6", DataTypes.STRING()); + schemaBuilder.column("f7", DataTypes.STRING()); + schemaBuilder.column("f8", DataTypes.STRING()); + schemaBuilder.column("f9", DataTypes.STRING()); + Schema schema = schemaBuilder.build(); + + catalog.createDatabase("pulsar_paimon", true); + catalog.createTable(identifier, schema, true); + return catalog.getTable(identifier); + } catch (Catalog.TableNotExistException e) { + // do something + throw new RuntimeException("table not exist"); + } catch (Catalog.TableAlreadyExistException e) { + throw new RuntimeException(e); + } catch (Catalog.DatabaseNotExistException e) { + throw new RuntimeException(e); + } catch (Catalog.DatabaseAlreadyExistException e) { + throw new RuntimeException(e); + } + } +} \ No newline at end of file diff --git a/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/PaimonWriter.java b/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/PaimonWriter.java new file mode 100644 index 0000000..3c5fa29 --- /dev/null +++ b/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/PaimonWriter.java @@ -0,0 +1,58 @@ +package org.apache.pulsar.ecosystem.io.paimon.sink; + +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.ObjectMapper; +import lombok.extern.slf4j.Slf4j; +import org.apache.paimon.data.BinaryString; +import org.apache.paimon.data.GenericRow; +import org.apache.paimon.table.sink.StreamTableWrite; +import org.apache.pulsar.client.api.schema.GenericRecord; + +@Slf4j +public class PaimonWriter { + private static final ObjectMapper objectMapper = new ObjectMapper(); + + public static synchronized void write(GenericRecord message, StreamTableWrite write) throws Exception { + // 转换 GenericRecord 到 GenericRow + GenericRow row = convertToRow(message); + log.info("record = {}, write a message to paimon",message); + write.write(row,1); + } + + //GenericRecord 到 GenericRow 的转换逻辑 + private static GenericRow convertToRow(GenericRecord record) throws JsonProcessingException { + GenericRow row = new GenericRow(10); + + row.setField(0, BinaryString.fromString((String) record.getField("messageId"))); + log.info("messageId is {}", record.getField("messageId")); + + row.setField(1, BinaryString.fromString((String) record.getField("address"))); + log.info("address is {}", record.getField("address")); + + row.setField(2, BinaryString.fromString((String) record.getField("subscription"))); + log.info("subscription is {}", record.getField("subscription")); + + row.setField(3, BinaryString.fromString((String) record.getField("topic"))); + log.info("topic is {}", record.getField("topic")); + + row.setField(4, BinaryString.fromString((String) record.getField("partition"))); + log.info("partition is {}", record.getField("partition")); + + row.setField(5, BinaryString.fromString((String) record.getField("event"))); + log.info("event is {}", record.getField("event")); + + row.setField(6, BinaryString.fromString((String) record.getField("producerName"))); + log.info("producerName is {}", record.getField("producerName")); + + row.setField(7, BinaryString.fromString((String) record.getField("consumerName"))); + log.info("consumerName is {}", record.getField("consumerName")); + + row.setField(8, BinaryString.fromString((String) record.getField("producerId"))); + log.info("producerId is {}", record.getField("producerId")); + + row.setField(9, BinaryString.fromString((String) record.getField("consumerId"))); + log.info("consumerId is {}", record.getField("consumerId")); + + return row; + } +} \ No newline at end of file diff --git a/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/SinkConnector.java b/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/SinkConnector.java new file mode 100644 index 0000000..f1bdd8c --- /dev/null +++ b/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/SinkConnector.java @@ -0,0 +1,99 @@ +package org.apache.pulsar.ecosystem.io.paimon.sink; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.google.common.collect.Lists; +import java.util.List; +import org.apache.paimon.data.InternalRow; +import org.apache.paimon.predicate.Predicate; +import org.apache.paimon.predicate.PredicateBuilder; +import org.apache.paimon.reader.RecordReader; +import org.apache.paimon.table.Table; +import org.apache.paimon.table.sink.CommitMessage; +import org.apache.paimon.table.sink.StreamTableCommit; +import org.apache.paimon.table.sink.StreamTableWrite; +import org.apache.paimon.table.sink.StreamWriteBuilder; +import org.apache.paimon.table.source.ReadBuilder; +import org.apache.paimon.table.source.Split; +import org.apache.paimon.table.source.TableRead; +import org.apache.paimon.types.DataTypes; +import org.apache.paimon.types.RowType; +import org.apache.pulsar.functions.api.Record; +import org.apache.pulsar.io.core.Sink; +import org.apache.pulsar.io.core.SinkContext; +import org.apache.pulsar.client.api.schema.GenericRecord; +import lombok.extern.slf4j.Slf4j; + +import java.util.Map; + +@Slf4j +public class SinkConnector implements Sink { + + private final PaimonWriter paimonWriter = new PaimonWriter(); + StreamTableWrite write; + Table table; + StreamWriteBuilder writeBuilder; + int count = 0; + long commitIdentifier = 0; + + @Override + public void open(Map configMap, SinkContext sinkContext) throws Exception { + // 1. Create a WriteBuilder (Serializable) + table = GetTable.getTable(); + writeBuilder = table.newStreamWriteBuilder(); + + // 2. Write records in distributed tasks + this.write = writeBuilder.newWrite(); + + } + + @Override + public void write(Record record) throws Exception { + count++; + GenericRecord value = record.getMessage().get().getValue(); + paimonWriter.write(value,write); + + List messages = write.prepareCommit(false, commitIdentifier); + commitIdentifier++; + + // 3. Collect all CommitMessages to a global node and commit + StreamTableCommit commit = writeBuilder.newCommit(); + commit.commit(commitIdentifier, messages); + + if(commitIdentifier % 1000 == 0){ + //调用flink api从paimon中读取数据，验证数据是否写入成功 + PredicateBuilder builder = + new PredicateBuilder(RowType.of(DataTypes.STRING(), DataTypes.STRING(), + DataTypes.STRING(), DataTypes.STRING(), DataTypes.STRING(), + DataTypes.STRING(), DataTypes.STRING(), DataTypes.STRING(), + DataTypes.STRING(), DataTypes.STRING())); + Predicate notNull = builder.isNotNull(0); + + int[] projection = new int[] {0, 1, 2, 3, 4, 5, 6}; + + ReadBuilder readBuilder = + table.newReadBuilder() + .withProjection(projection) + .withFilter(Lists.newArrayList(notNull)); + + // 2. Plan splits in 'Coordinator' (or named 'Driver') + List splits = readBuilder.newScan().plan().splits(); + + // 3. Distribute these splits to different tasks + + // 4. Read a split in task + TableRead read = readBuilder.newRead(); + RecordReader reader = read.createReader(splits); + reader.forEachRemaining(row -> { + String msg = row.getString(0) + ":" + row.getString(1)+ ":" + row.getString(2)+ + ":" + row.getString(3) + + ":" + row.getString(4)+ ":" + row.getString(5)+ ":" + row.getString(6); + log.info("msg: " + msg); + }); + } + } + + @Override + public void close() throws Exception { + log.info("Paimon Sink Connector closed."); + } +} \ No newline at end of file diff --git a/pulsar-paimon-sink/src/main/resources/META-INF/services/pulsar-io.yaml b/pulsar-paimon-sink/src/main/resources/META-INF/services/pulsar-io.yaml new file mode 100644 index 0000000..b9e9799 --- /dev/null +++ b/pulsar-paimon-sink/src/main/resources/META-INF/services/pulsar-io.yaml @@ -0,0 +1,4 @@ +name: paimon-sink +description: Paimon Sink Connector +sinkClass: org.apache.pulsar.ecosystem.io.paimon.sink.SinkConnector +sinkConfigClass: org.apache.pulsar.ecosystem.io.paimon.sink.SinkConnectorConfig \ No newline at end of file diff --git a/pulsar-paimon-sink/target/.plxarc b/pulsar-paimon-sink/target/.plxarc new file mode 100644 index 0000000..67ea6ee --- /dev/null +++ b/pulsar-paimon-sink/target/.plxarc @@ -0,0 +1 @@ +maven-shared-archive-resources \ No newline at end of file diff --git a/pulsar-paimon-sink/target/classes/META-INF/services/pulsar-io.yaml b/pulsar-paimon-sink/target/classes/META-INF/services/pulsar-io.yaml new file mode 100644 index 0000000..b9e9799 --- /dev/null +++ b/pulsar-paimon-sink/target/classes/META-INF/services/pulsar-io.yaml @@ -0,0 +1,4 @@ +name: paimon-sink +description: Paimon Sink Connector +sinkClass: org.apache.pulsar.ecosystem.io.paimon.sink.SinkConnector +sinkConfigClass: org.apache.pulsar.ecosystem.io.paimon.sink.SinkConnectorConfig \ No newline at end of file diff --git a/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/CreateCatalog.class b/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/CreateCatalog.class new file mode 100644 index 0000000..dc1c4a4 Binary files /dev/null and b/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/CreateCatalog.class differ diff --git a/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/GetTable.class b/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/GetTable.class new file mode 100644 index 0000000..b85371b Binary files /dev/null and b/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/GetTable.class differ diff --git a/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/PaimonWriter.class b/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/PaimonWriter.class new file mode 100644 index 0000000..6cc250f Binary files /dev/null and b/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/PaimonWriter.class differ diff --git a/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/SinkConnector.class b/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/SinkConnector.class new file mode 100644 index 0000000..023e6bc Binary files /dev/null and b/pulsar-paimon-sink/target/classes/org/apache/pulsar/ecosystem/io/paimon/sink/SinkConnector.class differ diff --git a/pulsar-paimon-sink/target/maven-archiver/pom.properties b/pulsar-paimon-sink/target/maven-archiver/pom.properties new file mode 100644 index 0000000..fb1b5ab --- /dev/null +++ b/pulsar-paimon-sink/target/maven-archiver/pom.properties @@ -0,0 +1,5 @@ +#Created by Apache Maven 3.9.9 +#Fri Nov 22 03:56:32 UTC 2024 +groupId=org.apache.pulsar.ecosystem +artifactId=pulsar-io-paimon +version=2.11.0-SNAPSHOT diff --git a/pulsar-paimon-sink/target/maven-shared-archive-resources/META-INF/DEPENDENCIES b/pulsar-paimon-sink/target/maven-shared-archive-resources/META-INF/DEPENDENCIES new file mode 100644 index 0000000..44809c9 --- /dev/null +++ b/pulsar-paimon-sink/target/maven-shared-archive-resources/META-INF/DEPENDENCIES @@ -0,0 +1,279 @@ +// ------------------------------------------------------------------ +// Transitive dependencies of this project determined from the +// maven pom organized by organization. +// ------------------------------------------------------------------ + +Pulsar Ecosystem :: IO Connector :: Lake House + + +From: 'an unknown organization' + - Caffeine cache (https://github.com/ben-manes/caffeine) com.github.ben-manes.caffeine:caffeine:jar:2.9.3 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - JCIP Annotations under Apache License (http://stephenc.github.com/jcip-annotations) com.github.stephenc.jcip:jcip-annotations:jar:1.0-1 + License: Apache License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - FindBugs-jsr305 (http://findbugs.sourceforge.net/) com.google.code.findbugs:jsr305:jar:1.3.9 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - error-prone annotations (http://nexus.sonatype.org/oss-repository-hosting.html/error_prone_parent/error_prone_annotations) com.google.errorprone:error_prone_annotations:jar:2.2.0 + License: Apache 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Guava InternalFutureFailureAccess and InternalFutures (https://github.com/google/guava/failureaccess) com.google.guava:failureaccess:jar:1.0 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Guava: Google Core Libraries for Java (https://github.com/google/guava/guava) com.google.guava:guava:bundle:27.0-jre + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Guava ListenableFuture only (https://github.com/google/guava/listenablefuture) com.google.guava:listenablefuture:jar:9999.0-empty-to-avoid-conflict-with-guava + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - J2ObjC Annotations (https://github.com/google/j2objc/) com.google.j2objc:j2objc-annotations:jar:1.1 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - re2j (http://github.com/google/re2j) com.google.re2j:re2j:jar:1.1 + License: The Go license (https://golang.org/LICENSE) + - OkHttp (https://github.com/square/okhttp/okhttp) com.squareup.okhttp:okhttp:jar:2.7.5 + License: Apache 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Okio (https://github.com/square/okio/okio) com.squareup.okio:okio:jar:1.6.0 + License: Apache 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - ParaNamer Core (http://paranamer.codehaus.org/paranamer) com.thoughtworks.paranamer:paranamer:jar:2.3 + License: BSD (LICENSE.txt) + - dnsjava (http://www.dnsjava.org) dnsjava:dnsjava:jar:2.1.7 + License: BSD 2-Clause license (http://opensource.org/licenses/BSD-2-Clause) + - aircompressor (https://github.com/airlift/aircompressor) io.airlift:aircompressor:jar:0.27 + License: Apache License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.html) + - jsp-api javax.servlet.jsp:jsp-api:jar:2.1 + + - Checker Qual (https://checkerframework.org) org.checkerframework:checker-qual:jar:2.5.2 + License: The MIT License (http://opensource.org/licenses/MIT) + - LZ4 and xxHash (https://github.com/lz4/lz4-java) org.lz4:lz4-java:jar:1.8.0 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - SnakeYAML (https://bitbucket.org/snakeyaml/snakeyaml) org.yaml:snakeyaml:bundle:1.33 + License: Apache License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'Apache Software Foundation' (http://www.apache.org) + - Apache Log4j (http://logging.apache.org/log4j/1.2/) log4j:log4j:bundle:1.2.17 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'Apache Software Foundation' (https://www.apache.org) + - Apache Hadoop Annotations org.apache.hadoop:hadoop-annotations:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop Auth org.apache.hadoop:hadoop-auth:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop Client Aggregator org.apache.hadoop:hadoop-client:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop Common org.apache.hadoop:hadoop-common:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop HDFS Client org.apache.hadoop:hadoop-hdfs-client:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop MapReduce Common org.apache.hadoop:hadoop-mapreduce-client-common:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop MapReduce Core org.apache.hadoop:hadoop-mapreduce-client-core:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop MapReduce JobClient org.apache.hadoop:hadoop-mapreduce-client-jobclient:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop YARN API org.apache.hadoop:hadoop-yarn-api:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop YARN Client org.apache.hadoop:hadoop-yarn-client:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Hadoop YARN Common org.apache.hadoop:hadoop-yarn-common:jar:3.2.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'Apache Software Foundation' (https://www.apache.org/) + - Pulsar Client Admin :: API (https://github.com/apache/pulsar/pulsar-client-admin-api) org.apache.pulsar:pulsar-client-admin-api:jar:3.0.7 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Pulsar Client :: API (https://github.com/apache/pulsar/pulsar-client-api) org.apache.pulsar:pulsar-client-api:jar:3.0.7 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Pulsar Functions :: API (https://github.com/apache/pulsar/pulsar-functions/pulsar-functions-api) org.apache.pulsar:pulsar-functions-api:jar:3.0.7 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Pulsar IO :: IO (https://github.com/apache/pulsar/pulsar-io/pulsar-io-core) org.apache.pulsar:pulsar-io-core:jar:3.0.7 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'Chemouni Uriel' (http://www.minidev.net/) + - ASM based accessors helper used by json-smart (http://www.minidev.net/) net.minidev:accessors-smart:bundle:1.2 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - JSON Small and Fast Parser (http://www.minidev.net/) net.minidev:json-smart:bundle:2.3 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'com.github.luben' + - zstd-jni (https://github.com/luben/zstd-jni) com.github.luben:zstd-jni:jar:1.5.5-11 + License: BSD 2-Clause License (https://opensource.org/licenses/BSD-2-Clause) + +From: 'Connect2id Ltd.' (http://connect2id.com) + - Nimbus JOSE+JWT (https://bitbucket.org/connect2id/nimbus-jose-jwt) com.nimbusds:nimbus-jose-jwt:jar:4.41.1 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'FasterXML' (http://fasterxml.com) + - Woodstox (https://github.com/FasterXML/woodstox) com.fasterxml.woodstox:woodstox-core:bundle:5.0.3 + License: The Apache License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Jackson (http://jackson.codehaus.org) org.codehaus.jackson:jackson-core-asl:jar:1.9.13 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Data Mapper for Jackson (http://jackson.codehaus.org) org.codehaus.jackson:jackson-mapper-asl:jar:1.9.13 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'FasterXML' (http://fasterxml.com/) + - Jackson-annotations (https://github.com/FasterXML/jackson) com.fasterxml.jackson.core:jackson-annotations:jar:2.15.0 + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Jackson-core (https://github.com/FasterXML/jackson-core) com.fasterxml.jackson.core:jackson-core:jar:2.15.0 + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - jackson-databind (https://github.com/FasterXML/jackson) com.fasterxml.jackson.core:jackson-databind:jar:2.15.0 + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Jackson-dataformat-CSV (https://github.com/FasterXML/jackson-dataformats-text) com.fasterxml.jackson.dataformat:jackson-dataformat-csv:bundle:2.14.2 + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Jackson-dataformat-YAML (https://github.com/FasterXML/jackson-dataformats-text) com.fasterxml.jackson.dataformat:jackson-dataformat-yaml:bundle:2.14.2 + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Jackson datatype: jdk8 (https://github.com/FasterXML/jackson-modules-java8/jackson-datatype-jdk8) com.fasterxml.jackson.datatype:jackson-datatype-jdk8:bundle:2.14.2 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Jackson datatype: JSR310 (https://github.com/FasterXML/jackson-modules-java8/jackson-datatype-jsr310) com.fasterxml.jackson.datatype:jackson-datatype-jsr310:bundle:2.14.2 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Jackson-JAXRS-base (http://github.com/FasterXML/jackson-jaxrs-providers/jackson-jaxrs-base) com.fasterxml.jackson.jaxrs:jackson-jaxrs-base:bundle:2.9.8 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Jackson-JAXRS-JSON (http://github.com/FasterXML/jackson-jaxrs-providers/jackson-jaxrs-json-provider) com.fasterxml.jackson.jaxrs:jackson-jaxrs-json-provider:bundle:2.9.8 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Jackson module: JAXB Annotations (https://github.com/FasterXML/jackson-modules-base) com.fasterxml.jackson.module:jackson-module-jaxb-annotations:bundle:2.9.8 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'fasterxml.com' (http://fasterxml.com) + - Stax2 API (http://wiki.fasterxml.com/WoodstoxStax2) org.codehaus.woodstox:stax2-api:bundle:3.1.4 + License: The BSD License (http://www.opensource.org/licenses/bsd-license.php) + +From: 'GlassFish Community' (https://glassfish.dev.java.net) + - Java Servlet API (http://servlet-spec.java.net) javax.servlet:javax.servlet-api:jar:3.1.0 + License: CDDL + GPLv2 with classpath exception (https://glassfish.dev.java.net/nonav/public/CDDL+GPL.html) + +From: 'Google' (http://www.google.com/) + - Protocol Buffer Java API (http://code.google.com/p/protobuf) com.google.protobuf:protobuf-java:bundle:2.5.0 + License: New BSD license (http://www.opensource.org/licenses/bsd-license.php) + +From: 'Google, Inc.' (http://www.google.com) + - Gson (http://code.google.com/p/google-gson/) com.google.code.gson:gson:jar:2.2.4 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'MojoHaus' (http://www.mojohaus.org) + - Animal Sniffer Annotations (http://www.mojohaus.org/animal-sniffer/animal-sniffer-annotations) org.codehaus.mojo:animal-sniffer-annotations:jar:1.17 + License: MIT license (http://www.opensource.org/licenses/mit-license.php) + +From: 'ObjectWeb' (http://www.objectweb.org/) + - ASM Core (http://asm.objectweb.org/asm/) org.ow2.asm:asm:jar:5.0.4 + License: BSD (http://asm.objectweb.org/license.html) + +From: 'Oracle Corporation' (http://www.oracle.com/) + - jersey-client (https://jersey.java.net/jersey-client/) com.sun.jersey:jersey-client:jar:1.19 + License: CDDL 1.1 (http://glassfish.java.net/public/CDDL+GPL_1_1.html) License: GPL2 w/ CPE (http://glassfish.java.net/public/CDDL+GPL_1_1.html) + - jersey-core (https://jersey.java.net/jersey-core/) com.sun.jersey:jersey-core:jar:1.19 + License: CDDL 1.1 (http://glassfish.java.net/public/CDDL+GPL_1_1.html) License: GPL2 w/ CPE (http://glassfish.java.net/public/CDDL+GPL_1_1.html) + - jersey-servlet (https://jersey.java.net/jersey-servlet/) com.sun.jersey:jersey-servlet:jar:1.19 + License: CDDL 1.1 (http://glassfish.java.net/public/CDDL+GPL_1_1.html) License: GPL2 w/ CPE (http://glassfish.java.net/public/CDDL+GPL_1_1.html) + - Java Architecture for XML Binding (http://jaxb.java.net/) javax.xml.bind:jaxb-api:jar:2.2.11 + License: CDDL 1.1 (https://glassfish.java.net/public/CDDL+GPL_1_1.html) License: GPL2 w/ CPE (https://glassfish.java.net/public/CDDL+GPL_1_1.html) + +From: 'QOS.ch' (http://www.qos.ch) + - SLF4J API Module (http://www.slf4j.org) org.slf4j:slf4j-api:jar:1.7.32 + License: MIT License (http://www.opensource.org/licenses/mit-license.php) + +From: 'Sun Microsystems, Inc' (http://www.sun.com/) + - jsr311-api (https://jsr311.dev.java.net) javax.ws.rs:jsr311-api:jar:1.1.1 + License: CDDL License (http://www.opensource.org/licenses/cddl1.php) + +From: 'The Apache Software Foundation' (http://www.apache.org/) + - Commons CLI (http://commons.apache.org/cli/) commons-cli:commons-cli:jar:1.2 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Commons Collections (http://commons.apache.org/collections/) commons-collections:commons-collections:jar:3.2.2 + License: Apache License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Commons IO (http://commons.apache.org/proper/commons-io/) commons-io:commons-io:jar:2.5 + License: Apache License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Commons Logging (http://commons.apache.org/proper/commons-logging/) commons-logging:commons-logging:jar:1.1.3 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Avro (http://avro.apache.org) org.apache.avro:avro:bundle:1.7.7 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Commons Math (http://commons.apache.org/proper/commons-math/) org.apache.commons:commons-math3:jar:3.6.1 + License: Apache License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Curator Client (http://curator.apache.org/curator-client) org.apache.curator:curator-client:bundle:2.13.0 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Curator Framework (http://curator.apache.org/curator-framework) org.apache.curator:curator-framework:bundle:2.13.0 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Curator Recipes (http://curator.apache.org/curator-recipes) org.apache.curator:curator-recipes:bundle:2.13.0 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - htrace-core4 (http://incubator.apache.org/projects/htrace.html) org.apache.htrace:htrace-core4:jar:4.1.0-incubating + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache HttpClient (http://hc.apache.org/httpcomponents-client) org.apache.httpcomponents:httpclient:jar:4.5.6 + License: Apache License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache HttpCore (http://hc.apache.org/httpcomponents-core-ga) org.apache.httpcomponents:httpcore:jar:4.4.10 + License: Apache License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'The Apache Software Foundation' (https://www.apache.org/) + - Apache Commons BeanUtils (https://commons.apache.org/proper/commons-beanutils/) commons-beanutils:commons-beanutils:jar:1.9.3 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Commons Codec (http://commons.apache.org/proper/commons-codec/) commons-codec:commons-codec:jar:1.11 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Commons Net (http://commons.apache.org/proper/commons-net/) commons-net:commons-net:jar:3.6 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Commons Compress (https://commons.apache.org/proper/commons-compress/) org.apache.commons:commons-compress:jar:1.18 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Commons Configuration (http://commons.apache.org/proper/commons-configuration/) org.apache.commons:commons-configuration2:jar:2.1.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Commons Lang (http://commons.apache.org/proper/commons-lang/) org.apache.commons:commons-lang3:jar:3.7 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Commons Text (http://commons.apache.org/proper/commons-text) org.apache.commons:commons-text:jar:1.4 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby-kerb Admin (http://directory.apache.org/kerby/kerby-kerb/kerb-admin) org.apache.kerby:kerb-admin:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby-kerb Client (http://directory.apache.org/kerby/kerby-kerb/kerb-client) org.apache.kerby:kerb-client:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby-kerb Common (http://directory.apache.org/kerby/kerby-kerb/kerb-common) org.apache.kerby:kerb-common:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby-kerb core (http://directory.apache.org/kerby/kerby-kerb/kerb-core) org.apache.kerby:kerb-core:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby-kerb Crypto (http://directory.apache.org/kerby/kerby-kerb/kerb-crypto) org.apache.kerby:kerb-crypto:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby-kerb Identity (http://directory.apache.org/kerby/kerby-kerb/kerb-identity) org.apache.kerby:kerb-identity:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby-kerb Server (http://directory.apache.org/kerby/kerby-kerb/kerb-server) org.apache.kerby:kerb-server:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerb Simple Kdc (http://directory.apache.org/kerby/kerby-kerb/kerb-simplekdc) org.apache.kerby:kerb-simplekdc:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby-kerb Util (http://directory.apache.org/kerby/kerby-kerb/kerb-util) org.apache.kerby:kerb-util:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby ASN1 Project (http://directory.apache.org/kerby/kerby-common/kerby-asn1) org.apache.kerby:kerby-asn1:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby Config (http://directory.apache.org/kerby/kerby-common/kerby-config) org.apache.kerby:kerby-config:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby PKIX Project (http://directory.apache.org/kerby/kerby-pkix) org.apache.kerby:kerby-pkix:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby Util (http://directory.apache.org/kerby/kerby-common/kerby-util) org.apache.kerby:kerby-util:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Kerby XDR Project (http://directory.apache.org/kerby/kerby-common/kerby-xdr) org.apache.kerby:kerby-xdr:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Token provider (http://directory.apache.org/kerby/kerby-provider/token-provider) org.apache.kerby:token-provider:jar:1.0.1 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Log4j API (https://logging.apache.org/log4j/2.x/log4j-api/) org.apache.logging.log4j:log4j-api:jar:2.17.2 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Log4j Core (https://logging.apache.org/log4j/2.x/log4j-core/) org.apache.logging.log4j:log4j-core:jar:2.17.2 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Apache Log4j SLF4J Binding (https://logging.apache.org/log4j/2.x/log4j-slf4j-impl/) org.apache.logging.log4j:log4j-slf4j-impl:jar:2.17.2 + License: Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Paimon : Code Gen Loader (https://paimon.apache.org/paimon-codegen-loader) org.apache.paimon:paimon-codegen-loader:jar:0.9.0 + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Paimon : Common (https://paimon.apache.org/paimon-common) org.apache.paimon:paimon-common:jar:0.9.0 + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - Paimon : Core (https://paimon.apache.org/paimon-core) org.apache.paimon:paimon-core:jar:0.9.0 + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - paimon-shade-caffeine-2 (https://paimon.apache.org/paimon-shade-caffeine-2) org.apache.paimon:paimon-shade-caffeine-2:jar:2.9.3-0.6.0-incubating + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - paimon-shade-guava-30 (https://paimon.apache.org/paimon-shade-guava-30) org.apache.paimon:paimon-shade-guava-30:jar:30.1.1-jre-0.6.0-incubating + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + - paimon-shade-jackson-2 (https://paimon.apache.org/paimon-shade-jackson-parent/paimon-shade-jackson-2) org.apache.paimon:paimon-shade-jackson-2:jar:2.14.2-0.6.0-incubating + License: The Apache Software License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt) + +From: 'Webtide' (http://webtide.com) + - Jetty :: Security (http://www.eclipse.org/jetty) org.eclipse.jetty:jetty-security:jar:9.3.24.v20180605 + License: Apache Software License - Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0) License: Eclipse Public License - Version 1.0 (http://www.eclipse.org/org/documents/epl-v10.php) + - Jetty :: Servlet Handling (http://www.eclipse.org/jetty) org.eclipse.jetty:jetty-servlet:jar:9.3.24.v20180605 + License: Apache Software License - Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0) License: Eclipse Public License - Version 1.0 (http://www.eclipse.org/org/documents/epl-v10.php) + - Jetty :: Utilities (http://www.eclipse.org/jetty) org.eclipse.jetty:jetty-util:jar:9.3.24.v20180605 + License: Apache Software License - Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0) License: Eclipse Public License - Version 1.0 (http://www.eclipse.org/org/documents/epl-v10.php) + - Jetty :: Webapp Application Support (http://www.eclipse.org/jetty) org.eclipse.jetty:jetty-webapp:jar:9.3.24.v20180605 + License: Apache Software License - Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0) License: Eclipse Public License - Version 1.0 (http://www.eclipse.org/org/documents/epl-v10.php) + - Jetty :: XML utilities (http://www.eclipse.org/jetty) org.eclipse.jetty:jetty-xml:jar:9.3.24.v20180605 + License: Apache Software License - Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0) License: Eclipse Public License - Version 1.0 (http://www.eclipse.org/org/documents/epl-v10.php) + +From: 'xerial.org' (http://www.xerial.org/) + - Snappy for Java (http://github.com/xerial/snappy-java/) org.xerial.snappy:snappy-java:bundle:1.0.5 + License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt) + + + + diff --git a/pulsar-paimon-sink/target/maven-shared-archive-resources/META-INF/LICENSE b/pulsar-paimon-sink/target/maven-shared-archive-resources/META-INF/LICENSE new file mode 100644 index 0000000..d645695 --- /dev/null +++ b/pulsar-paimon-sink/target/maven-shared-archive-resources/META-INF/LICENSE @@ -0,0 +1,202 @@ + + Apache License + Version 2.0, January 2004 + http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + "License" shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + "Licensor" shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + "Legal Entity" shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + "control" means (i) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + "You" (or "Your") shall mean an individual or Legal Entity + exercising permissions granted by this License. + + "Source" form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + "Object" form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + "Work" shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + "Derivative Works" shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + "Contribution" shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, "submitted" + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as "Not a Contribution." + + "Contributor" shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, + publicly display, publicly perform, sublicense, and distribute the + Work and such Derivative Works in Source or Object form. + + 3. Grant of Patent License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + (except as stated in this section) patent license to make, have made, + use, offer to sell, sell, import, and otherwise transfer the Work, + where such license applies only to those patent claims licensable + by such Contributor that are necessarily infringed by their + Contribution(s) alone or by combination of their Contribution(s) + with the Work to which such Contribution(s) was submitted. If You + institute patent litigation against any entity (including a + cross-claim or counterclaim in a lawsuit) alleging that the Work + or a Contribution incorporated within the Work constitutes direct + or contributory patent infringement, then any patent licenses + granted to You under this License for that Work shall terminate + as of the date such litigation is filed. + + 4. Redistribution. You may reproduce and distribute copies of the + Work or Derivative Works thereof in any medium, with or without + modifications, and in Source or Object form, provided that You + meet the following conditions: + + (a) You must give any other recipients of the Work or + Derivative Works a copy of this License; and + + (b) You must cause any modified files to carry prominent notices + stating that You changed the files; and + + (c) You must retain, in the Source form of any Derivative Works + that You distribute, all copyright, patent, trademark, and + attribution notices from the Source form of the Work, + excluding those notices that do not pertain to any part of + the Derivative Works; and + + (d) If the Work includes a "NOTICE" text file as part of its + distribution, then any Derivative Works that You distribute must + include a readable copy of the attribution notices contained + within such NOTICE file, excluding those notices that do not + pertain to any part of the Derivative Works, in at least one + of the following places: within a NOTICE text file distributed + as part of the Derivative Works; within the Source form or + documentation, if provided along with the Derivative Works; or, + within a display generated by the Derivative Works, if and + wherever such third-party notices normally appear. The contents + of the NOTICE file are for informational purposes only and + do not modify the License. You may add Your own attribution + notices within Derivative Works that You distribute, alongside + or as an addendum to the NOTICE text from the Work, provided + that such additional attribution notices cannot be construed + as modifying the License. + + You may add Your own copyright statement to Your modifications and + may provide additional or different license terms and conditions + for use, reproduction, or distribution of Your modifications, or + for any such Derivative Works as a whole, provided Your use, + reproduction, and distribution of the Work otherwise complies with + the conditions stated in this License. + + 5. Submission of Contributions. Unless You explicitly state otherwise, + any Contribution intentionally submitted for inclusion in the Work + by You to the Licensor shall be under the terms and conditions of + this License, without any additional terms or conditions. + Notwithstanding the above, nothing herein shall supersede or modify + the terms of any separate license agreement you may have executed + with Licensor regarding such Contributions. + + 6. Trademarks. This License does not grant permission to use the trade + names, trademarks, service marks, or product names of the Licensor, + except as required for reasonable and customary use in describing the + origin of the Work and reproducing the content of the NOTICE file. + + 7. Disclaimer of Warranty. Unless required by applicable law or + agreed to in writing, Licensor provides the Work (and each + Contributor provides its Contributions) on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + implied, including, without limitation, any warranties or conditions + of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A + PARTICULAR PURPOSE. You are solely responsible for determining the + appropriateness of using or redistributing the Work and assume any + risks associated with Your exercise of permissions under this License. + + 8. Limitation of Liability. In no event and under no legal theory, + whether in tort (including negligence), contract, or otherwise, + unless required by applicable law (such as deliberate and grossly + negligent acts) or agreed to in writing, shall any Contributor be + liable to You for damages, including any direct, indirect, special, + incidental, or consequential damages of any character arising as a + result of this License or out of the use or inability to use the + Work (including but not limited to damages for loss of goodwill, + work stoppage, computer failure or malfunction, or any and all + other commercial damages or losses), even if such Contributor + has been advised of the possibility of such damages. + + 9. Accepting Warranty or Additional Liability. While redistributing + the Work or Derivative Works thereof, You may choose to offer, + and charge a fee for, acceptance of support, warranty, indemnity, + or other liability obligations and/or rights consistent with this + License. However, in accepting such obligations, You may act only + on Your own behalf and on Your sole responsibility, not on behalf + of any other Contributor, and only if You agree to indemnify, + defend, and hold each Contributor harmless for any liability + incurred by, or claims asserted against, such Contributor by reason + of your accepting any such warranty or additional liability. + + END OF TERMS AND CONDITIONS + + APPENDIX: How to apply the Apache License to your work. + + To apply the Apache License to your work, attach the following + boilerplate notice, with the fields enclosed by brackets "[]" + replaced with your own identifying information. (Don't include + the brackets!) The text should be enclosed in the appropriate + comment syntax for the file format. We also recommend that a + file or class name and description of purpose be included on the + same "printed page" as the copyright notice for easier + identification within third-party archives. + + Copyright [yyyy] [name of copyright owner] + + Licensed under the Apache License, Version 2.0 (the "License"); + you may not use this file except in compliance with the License. + You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. diff --git a/pulsar-paimon-sink/target/maven-shared-archive-resources/META-INF/NOTICE b/pulsar-paimon-sink/target/maven-shared-archive-resources/META-INF/NOTICE new file mode 100644 index 0000000..c435fb7 --- /dev/null +++ b/pulsar-paimon-sink/target/maven-shared-archive-resources/META-INF/NOTICE @@ -0,0 +1,8 @@ + +Pulsar Ecosystem :: IO Connector :: Lake House +Copyright 2024 The Apache Software Foundation + +This product includes software developed at +The Apache Software Foundation (http://www.apache.org/). + + diff --git a/pulsar-paimon-sink/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst b/pulsar-paimon-sink/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst new file mode 100644 index 0000000..551e906 --- /dev/null +++ b/pulsar-paimon-sink/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst @@ -0,0 +1,4 @@ +org/apache/pulsar/ecosystem/io/paimon/sink/CreateCatalog.class +org/apache/pulsar/ecosystem/io/paimon/sink/PaimonWriter.class +org/apache/pulsar/ecosystem/io/paimon/sink/SinkConnector.class +org/apache/pulsar/ecosystem/io/paimon/sink/GetTable.class diff --git a/pulsar-paimon-sink/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst b/pulsar-paimon-sink/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst new file mode 100644 index 0000000..8ab0920 --- /dev/null +++ b/pulsar-paimon-sink/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst @@ -0,0 +1,4 @@ +/root/paimon/code/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/SinkConnector.java +/root/paimon/code/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/PaimonWriter.java +/root/paimon/code/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/CreateCatalog.java +/root/paimon/code/pulsar-paimon-sink/src/main/java/org/apache/pulsar/ecosystem/io/paimon/sink/GetTable.java diff --git a/pulsar-paimon-sink/target/original-pulsar-io-paimon-2.11.0-SNAPSHOT.jar b/pulsar-paimon-sink/target/original-pulsar-io-paimon-2.11.0-SNAPSHOT.jar new file mode 100644 index 0000000..301be67 Binary files /dev/null and b/pulsar-paimon-sink/target/original-pulsar-io-paimon-2.11.0-SNAPSHOT.jar differ diff --git a/pulsar-paimon-sink/target/pulsar-io-paimon-2.11.0-SNAPSHOT.jar b/pulsar-paimon-sink/target/pulsar-io-paimon-2.11.0-SNAPSHOT.jar new file mode 100644 index 0000000..655f7e7 Binary files /dev/null and b/pulsar-paimon-sink/target/pulsar-io-paimon-2.11.0-SNAPSHOT.jar differ