13 Commits

Author	SHA1	Message	Date
Lixin Wei	f31ee84bfd	[Streaming] Fault Tolerance Implementation (#10595)	2020-09-05 16:40:47 +08:00
SangBin Cho	cb919c5e5c	Revert "[Streaming] Fault Tolerance Implementation (#10008)" (#10582) ... This reverts commit 1b1466748f.	2020-09-04 13:21:18 -07:00
Lixin Wei	1b1466748f	[Streaming] Fault Tolerance Implementation (#10008)	2020-09-04 20:44:34 +08:00
Siyuan (Ryans) Zhuang	54a0d8b69e	[Core] Try remove all windows compat shims (#9671) ... * try remove compat for arrow * remove unistd.h * remove socket compat * delete arrow windows patch	2020-07-25 12:00:36 -07:00
Lingxuan Zuo	58a38e81d1	use help proto-init-macro for streaming config (#9272)	2020-07-24 17:59:33 +08:00
mehrdadn	2554a1a997	Bazel fixes (#9519)	2020-07-19 12:53:08 -07:00
Siyuan (Ryans) Zhuang	b68fede30b	Convert include guard to pragma once (#8957)	2020-06-16 01:29:43 -07:00
chaokunyang	5cf49d5edd	Fix streaming ci (#8159)	2020-04-26 20:56:58 +08:00
chaokunyang	8b6784de06	[Streaming] Streaming Python API (#6755)	2020-02-25 10:33:33 +08:00
Lingxuan Zuo	f995099e00	[Streaming] Support streaming flow control (#7152) ... * streaming writer use event driven model. * add RefreshChannelInfo * fix name * minor changes according reviewer comments * Fix according to reviewer's comments * fix bazel lint * code polished * Add more comments * rename Stop & Start of EventQueue to Freeze and Unfreeze. * add override * fix * fix return value * support flow control * add flow control ut in mock transfer * minor changes according to comments * add java and python worker adaption Co-authored-by: wanxing <wanxing.wwx@alibaba-inc.com>	2020-02-24 23:48:04 +08:00
Lingxuan Zuo	7e484687d3	Use GET-SET macro to reduce duplicated code. (#6863)	2020-01-21 10:57:57 +08:00
wanxing	40211bed4b	[Streaming]Fix default JobID (#6436)	2019-12-12 14:37:17 +08:00
Chaokun Yang	6272907a57	[Streaming] Streaming data transfer and python integration (#6185)	2019-12-10 20:33:24 +08:00