4.0.0 tech.streamfusion StreamFusion 0.1.0-rc3 pom StreamFusion Native Rust and Apache Arrow/DataFusion acceleration for Apache Flink SQL. https://streamfusion.tech/ Apache License, Version 2.0 https://www.apache.org/licenses/LICENSE-2.0 repo Jordan Epstein 32082339+jordepic@users.noreply.github.com datafusion-contrib https://github.com/datafusion-contrib streamfusion-runtime streamfusion-core streamfusion-kafka streamfusion-json streamfusion-csv streamfusion-raw streamfusion-avro streamfusion-avro-confluent-registry streamfusion-protobuf streamfusion-parquet streamfusion-orc streamfusion-loader scm:git:https://github.com/datafusion-contrib/StreamFusion.git scm:git:ssh://git@github.com/datafusion-contrib/StreamFusion.git https://github.com/datafusion-contrib/StreamFusion 2.12 0.5C 4.4.0 17 false 2.0.0 2.2.1 4.2.0 debug 0.1.0-rc3 build 17 streamfusion 4.32.1 UTF-8 18.3.0 tech/streamfusion/native 5.10.2 false ${project.basedir}/../native/target/${native.profile} -p streamfusion org.junit.jupiter junit-jupiter ${junit.version} test org.apache.arrow arrow-vector ${arrow.version} org.apache.arrow arrow-c-data ${arrow.version} org.apache.arrow arrow-memory-unsafe ${arrow.version} runtime org.apache.flink flink-table-api-java-bridge ${flink.version} provided org.apache.flink flink-table-planner_${scala.binary.version} ${flink.version} provided org.apache.flink flink-clients ${flink.version} provided org.apache.flink flink-runtime ${flink.version} test-jar test org.apache.flink flink-test-utils-junit ${flink.version} test org.apache.flink flink-statebackend-rocksdb ${flink.version} provided org.apache.flink flink-test-utils ${flink.version} test org.apache.flink flink-connector-files ${flink.version} provided org.apache.flink flink-connector-kafka 5.0.0-2.2 provided org.apache.flink flink-json ${flink.version} provided org.apache.flink flink-avro ${flink.version} provided org.apache.flink flink-avro-confluent-registry ${flink.version} test org.apache.flink flink-csv ${flink.version} provided org.apache.flink flink-parquet ${flink.version} test org.apache.flink flink-orc ${flink.version} provided org.apache.flink flink-protobuf ${flink.version} test com.google.protobuf protobuf-java ${protobuf.version} test org.apache.hadoop hadoop-common 3.3.4 provided org.apache.hadoop hadoop-mapreduce-client-core 3.3.4 test org.apache.kafka kafka-clients ${kafka.clients.version} provided org.testcontainers kafka 1.21.4 test org.testcontainers minio 1.21.4 test org.apache.flink flink-s3-fs-hadoop ${flink.version} test confluent https://packages.confluent.io/maven/ kr.motd.maven os-maven-plugin 1.7.1 ${project.basedir}/../src/main/resources true ${project.basedir}/../src/main/resources-filtered ${native.resource.path} ${native.resource.directory} lib${native.library}.so lib${native.library}.dylib maven-javadoc-plugin 3.11.2 none true tech/streamfusion/delta/** tech/streamfusion/planner/DeltaPlannerExtension.java tech/streamfusion/planner/DeltaSinkMatcher.java tech/streamfusion/planner/NativeDeltaSinkExecNode.java tech/streamfusion/planner/StreamPhysicalNativeDeltaSink.java tech/streamfusion/paimon/** tech/streamfusion/planner/Paimon*.java tech/streamfusion/planner/NativePaimon*.java tech/streamfusion/planner/StreamPhysicalNativePaimon*.java io.delta delta-flink_2.2 ${delta.version} io.delta delta-kernel-api ${delta.version} org.apache.parquet parquet-hadoop 1.16.0 org.apache.hadoop hadoop-common 3.3.4 org.apache.paimon paimon-flink-2.2 ${paimon.version} org.xolstice.maven.plugins protobuf-maven-plugin 0.6.1 generate-test-protobuf generate-test-sources test-compile com.google.protobuf:protoc:${protobuf.version}:exe:${os.detected.classifier} org.codehaus.mojo exec-maven-plugin 3.2.0 build-native test-compile exec ${native.build.skip} cargo ${project.basedir}/../native ${native.cargo.args} ${native.cargo.packages} maven-resources-plugin 3.3.1 copy-test-native-resource test-compile copy-resources ${native.test.resource.skip} ${project.build.outputDirectory} ${native.resource.directory} ${native.resource.path} lib${native.library}.so lib${native.library}.dylib maven-surefire-plugin 3.2.5 ${sf.testForks} true -Xmx8g -Djava.library.path=${project.basedir}/../native/target/${native.profile} -Dstreamfusion.native.development=true -Darrow.enable_unsafe_memory_access=true -Darrow.enable_null_check_for_get=false --add-opens=java.base/java.nio=ALL-UNNAMED --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.base/java.io=ALL-UNNAMED --add-opens=java.base/java.net=ALL-UNNAMED --add-opens=java.base/java.util.concurrent=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED --add-opens=java.base/java.lang.reflect=ALL-UNNAMED --add-opens=java.base/sun.nio.ch=ALL-UNNAMED ${sf.extraJvmArgs} ${sf.benchmarkJvmArgs} maven-shade-plugin 3.5.3 attach-runtime-payload package shade true runtime false *:* META-INF/*.SF META-INF/*.DSA META-INF/*.RSA maven-javadoc-plugin check-javadoc process-test-classes javadoc release org.codehaus.mojo flatten-maven-plugin 1.6.0 flatten-release-pom process-resources flatten resolveCiFriendliesOnly true maven-source-plugin 3.3.1 attach-sources jar-no-fork true maven-javadoc-plugin attach-javadocs jar maven-gpg-plugin 3.2.8 sign-release-artifacts verify sign --pinentry-mode loopback org.sonatype.central central-publishing-maven-plugin 0.11.0 true central ${central.autoPublish} ${central.waitUntil} true published flink-source-suite streamfusion.flink-source-suite org.codehaus.mojo flatten-maven-plugin 1.6.0 flatten-flink-source-suite-pom process-resources flatten resolveCiFriendliesOnly true org.apache.flink flink-sql-parser ${flink.version} provided org.apache.flink flink-table-calcite-bridge ${flink.version} provided org.apache.calcite calcite-core 1.36.0 provided bench build --release --features mimalloc 1 -Dstreamfusion.exchange.zeroCopyLocal=false release dist build --release --features mimalloc release universal ${native.resource.path} ${project.basedir}/../native/target/universal **/libstreamfusion.so **/libstreamfusion.dylib true ${project.basedir}/../native/target/no-local-payload image-it streamfusion-image-it delta streamfusion-delta paimon streamfusion-paimon