 Lixin Wei
|
aea3d53545
|
[Streaming] Supports multiple downstream collector (#9240)
|
2020-07-03 11:05:07 +08:00 |
|
|
chaokunyang
|
5edddf6eac
|
[Streaming] operator chain (#8910)
|
2020-06-18 15:11:07 +08:00 |
|
|
chaokunyang
|
dfa4768fc6
|
[Java] Refactor java api (#8858)
|
2020-06-12 10:49:01 +08:00 |
|
|
chaokunyang
|
700d81fa20
|
[Java] Remove java api sub package from test module (#8853)
|
2020-06-11 14:59:45 +08:00 |
|
|
Tianyi Chen
|
ec5ecb661f
|
[Streaming] Implement streaming job-worker. (#8780)
|
2020-06-10 14:13:55 +08:00 |
|
|
chaokunyang
|
d2ef29f0d2
|
[Streaming] Fix streaming word count tests (#8697)
|
2020-06-09 11:49:19 +08:00 |
|
|
chaokunyang
|
31a4d07bc4
|
[Java] Rename java ObjectRef/ActorHandle (#8799)
|
2020-06-09 11:40:43 +08:00 |
|
|
chaokunyang
|
d04953ab3c
|
[Streaming] Union api (#8612)
|
2020-06-08 14:28:11 +08:00 |
|
|
chaokunyang
|
bcdbe2d3d4
|
Streaming rich function (#8602)
|
2020-05-27 18:36:07 +08:00 |
|
|
chaokunyang
|
91f630f709
|
[Streaming] Streaming Cross-Lang API (#7464)
|
2020-04-29 13:42:08 +08:00 |
|
|
Tianyi Chen
|
0204dff1e9
|
[streaming]Add master and scheduler. (#8044)
|
2020-04-22 14:43:56 +08:00 |
|
|
wanxing
|
9345d03ffb
|
[Streaming] Streaming data transfer supports cross language. (#7961)
* add init parameters for java
* fix bug
* cython
* fix compile
* fix test_direct_tranfer
* comment
* ChannelCreationParameter
* fix comment
* builder
* lint and fix tests
* fix single process test
* fix checkstyle and lint
* checkstyle
* lint python
Co-authored-by: wanxing <wanxing@B-458DMD6M-1753.local>
|
2020-04-16 15:16:48 +08:00 |
|
|
JianZhangYang
|
7b0518b993
|
[streaming] Async changes for resourcemanager part (#7955)
|
2020-04-16 14:15:45 +08:00 |
|
|
Qing Wang
|
98bfcd53bc
|
[Java] Rename group id and package name. (#7864)
* 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
|
2020-04-12 17:59:34 +08:00 |
|
|
Tianyi Chen
|
c5bf9cc472
|
[streaming] Sync changes for graph part. (#7827)
|
2020-04-09 12:30:44 +08:00 |
|
|
Kai Yang
|
48b48cc8c2
|
Support multiple core workers in one process (#7623)
|
2020-04-07 11:01:47 +08:00 |
|
|
Tianyi Chen
|
f889f938e5
|
[streaming] Use enum to define resource type. (#7813)
|
2020-03-31 00:03:49 +08:00 |
|
|
Qing Wang
|
f4656d8cc3
|
[Java] Enable direct call by default. (#7408)
* WIP
* Address comments.
* Linting
* Fix
* Fix
* Fix test
* Fix
* Fix single process ci
* Fix ut
* Update java/test/src/main/java/org/ray/api/test/PlasmaFreeTest.java
* Address comments
* Fix linting
* Minor update comments.
* Fix streaming CI
|
2020-03-13 12:25:30 +08:00 |
|
|
Tianyi Chen
|
6993a471f1
|
[Streaming] Move resource-manager and scheduler to master package. (#7582)
|
2020-03-13 12:24:37 +08:00 |
|
|
Hao Chen
|
fe7820fec9
|
[Java] New Java actor API (#7414)
|
2020-03-04 22:39:23 +08:00 |
|
|
chaokunyang
|
8b6784de06
|
[Streaming] Streaming Python API (#6755)
|
2020-02-25 10:33:33 +08:00 |
|
|
JianZhangYang
|
7e115490d9
|
Streaming scheduler resourcemanager (#7070)
|
2020-02-24 19:32:50 +08:00 |
|
|
Tianyi Chen
|
13882d052d
|
[Streaming] Streaming scheduler - part1-2: execution graph (#6666)
|
2020-02-04 11:51:21 +08:00 |
|
|
chaokunyang
|
fa3c513276
|
[Streaming] Streaming filter transform (#6816)
* add filter transform
* lint
* add new line
|
2020-01-17 22:05:47 +08:00 |
|
|
Tianyi Chen
|
9a4da1951e
|
[Streaming] Streaming scheduler - part1-1: job graph (#6712)
|
2020-01-15 13:12:03 +08:00 |
|
|
chaokunyang
|
70c7d47c09
|
[Streaming] java cross lang streaming graph (#6689)
|
2020-01-08 17:32:35 +08:00 |
|
|
Tianyi Chen
|
9dacebec1a
|
[Streaming] Add configuration with owner config. (#6687)
|
2020-01-08 11:19:01 +08:00 |
|
|
Jing Ge
|
d39e76f2ce
|
rename interface and class for task assigner based on suitable pattern. (#6664)
|
2020-01-03 11:13:36 +08:00 |
|
|
Chaokun Yang
|
7bbfa85c66
|
[Streaming] Streaming data transfer java (#6474)
|
2019-12-22 10:56:05 +08:00 |
|