mirror of
https://github.com/wassname/ray.git
synced 2026-06-28 19:17:04 +08:00
98bfcd53bc
* Initial * Change streaming's * Fix * Fix * Fix org_ray * Fix cpp file name * Fix streaming * Fix * Fix * Fix testlistening * Fix missing sth in python * Fix * Fix * Fix SPI * Fix * Fix complation * Fix * Fix CI * Fix checkstyle Fix checkstyle * Fix streaming tests * Fix streaming CI * Fix streaming checkstyle. * Fix build * Fix bazel dep * Fix * Fix ray checkstyle * Fix streaming checkstyle * Fix bazel checkstyle
Ray Streaming
-
Build streaming java
- build ray
bazel build //java:gen_maven_depscd java && mvn clean install -Dmaven.test.skip=true && cd ..
- build streaming
bazel build //streaming/java:gen_maven_depsmvn clean install -Dmaven.test.skip=true
- build ray
-
Build ray python will build ray streaming python.
-
Run examples
# c++ test cd streaming/ && bazel test ... sh src/test/run_streaming_queue_test.sh cd .. # python test pushd python/ray/streaming/ pushd examples python simple.py --input-file toy.txt popd pushd tests pytest . popd popd # java test cd streaming/java/streaming-runtime mvn test