/beam-rust-jni

Primary LanguageRust

Running Rust entrypoint

Prerequisites

java -version
# 8.X

Build example with custom Beam SDK (Java)

Target example: beam/examples/java/src/main/java/org/apache/beam/examples/MySelect.java

cd beam
./gradlew -p examples/java/ shadowJar
ls -lh examples/java/build/libs/beam-examples-java-2.42.0-SNAPSHOT-all.jar

Run the pipeline from Rust

Run beam-flink backend:

docker run --net=host apache/beam_flink1.14_job_server:latest

And run the pipeline with beam-flink.

cd ..
DYLD_LIBRARY_PATH=$JAVA_HOME/lib cargo run