Lingxuan Zuo 3d9bd64591 [Streaming] DataWriter use event driven model. (#7043) ...

* streaming writer use event driven model.

* 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.

2020-02-11 22:24:45 +08:00

..

config

Use GET-SET macro to reduce duplicated code. (#6863)

2020-01-21 10:57:57 +08:00

lib/java

[xlang] Cross language Python support (#6709)

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

message

[streaming] Message bundle use inplacement instance (#6606)

2020-01-06 11:04:29 +08:00

protobuf

[Streaming] Streaming data transfer and python integration (#6185)

2019-12-10 20:33:24 +08:00

queue

[xlang] Cross language Python support (#6709)

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

test

[Streaming] DataWriter use event driven model. (#7043)

2020-02-11 22:24:45 +08:00

util

Polish Bazel build scripts (#6424)

2019-12-17 02:38:36 -08:00

channel.cc

[Streaming] DataWriter use event driven model. (#7043)

2020-02-11 22:24:45 +08:00

channel.h

[Streaming] DataWriter use event driven model. (#7043)

2020-02-11 22:24:45 +08:00

data_reader.cc

[Streaming] Streaming data transfer and python integration (#6185)

2019-12-10 20:33:24 +08:00

data_reader.h

[Streaming] Streaming data transfer and python integration (#6185)

2019-12-10 20:33:24 +08:00

data_writer.cc

[Streaming] DataWriter use event driven model. (#7043)

2020-02-11 22:24:45 +08:00

data_writer.h

[Streaming] DataWriter use event driven model. (#7043)

2020-02-11 22:24:45 +08:00

event_service.cc

[Streaming] DataWriter use event driven model. (#7043)

2020-02-11 22:24:45 +08:00

event_service.h

[Streaming] DataWriter use event driven model. (#7043)

2020-02-11 22:24:45 +08:00

ring_buffer.cc

[Streaming] DataWriter use event driven model. (#7043)

2020-02-11 22:24:45 +08:00

ring_buffer.h

[Streaming] DataWriter use event driven model. (#7043)

2020-02-11 22:24:45 +08:00

runtime_context.cc

[Streaming] Streaming data transfer and python integration (#6185)

2019-12-10 20:33:24 +08:00

runtime_context.h

[Streaming] Streaming data transfer and python integration (#6185)

2019-12-10 20:33:24 +08:00

status.h

[Streaming] Streaming data transfer and python integration (#6185)

2019-12-10 20:33:24 +08:00