mirror of https://github.com/wassname/ray.git synced 2026-06-30 05:41:19 +08:00

Files

T

mehrdadn e09f63ad65 Fix build errors and add more targets to Windows builds (#6811 )

* Fix common.fbs rename (due to apache/arrow/commit/bef9a1c251397311a6415d3dc362ef419d154caa)

* Add missing COPTS

* Use socketpair(AF_INET) if boost::asio::local is unavailable (e.g. on Windows)

* Fix compile bug in service_based_gcs_client_test.cc (fix build breakage in #6686)

* Work around googletest/gmock inability to specify override to avoid -Werror,-Winconsistent-missing-override

* Fix missing override on IsPlasmaBuffer()

* Fix missing libraries for streaming

* Factor out install-toolchains.sh

* Put some Bazel flags into .bazelrc

* Fix jni_md.h missing inclusion

* Add ~/bin to PATH for Bazel

* Change echo $$(date) > $@ to date > $@

* Fix lots of unquoted paths

* Add system() call checks for Windows

Co-authored-by: GitHub Web Flow <noreply@github.com>

2020-02-11 16:49:33 -08:00

java

Fix build errors and add more targets to Windows builds (#6811 )

2020-02-11 16:49:33 -08:00

python

[xlang] Cross language Python support (#6709 )

2020-02-08 13:01:28 +08:00

src

Fix build errors and add more targets to Windows builds (#6811 )

2020-02-11 16:49:33 -08:00

BUILD.bazel

Fix build errors and add more targets to Windows builds (#6811 )

2020-02-11 16:49:33 -08:00

README.md

[Streaming] Streaming data transfer java (#6474 )

2019-12-22 10:56:05 +08:00

README.md

Ray Streaming

Build streaming java
- build ray
  - bazel build //java:gen_maven_deps
  - cd java && mvn clean install -Dmaven.test.skip=true && cd ..
- build streaming
  - bazel build //streaming/java:gen_maven_deps
  - mvn clean install -Dmaven.test.skip=true
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