55 commits

Author	SHA1	Message	Date
yihaoDeng	74d5f02969	fix invalid free	2023-06-05 04:56:07 +00:00
Haojun Liao	e67b532d8a	refactor: refactor the module dependency.	2023-05-23 18:29:23 +08:00
Haojun Liao	de44c9160c	refactor: do some internal refactor.	2023-05-20 18:05:39 +08:00
Haojun Liao	aa7ea60bca	fix(stream): update the free strategy.	2023-05-20 15:43:48 +08:00
Haojun Liao	336102b8c5	refactor: do some internal refactor.	2023-05-20 13:34:49 +08:00
Haojun Liao	90687bae1c	refactor: do some internal refactor.	2023-05-19 15:30:50 +08:00
yihaoDeng	eb3ab4fcea	factor code	2023-05-11 13:34:17 +00:00
yihaoDeng	4e8f5f5d32	factor code	2023-05-11 09:58:53 +00:00
yihaoDeng	afaee9c386	factor code	2023-05-11 09:51:01 +00:00
yihaoDeng	4715aacd41	factor code	2023-05-11 09:44:40 +00:00
yihaoDeng	04c7c99a67	factor code	2023-05-11 09:17:05 +00:00
yihaoDeng	8be29dc98e	failed to open rocksdb cf	2023-05-06 10:35:23 +00:00
yihaoDeng	d7e86aca05	fix case failure	2023-05-05 15:14:16 +00:00
Haojun Liao	23c49594b7	other: merge main.	2023-05-04 16:41:53 +08:00
yihaoDeng	c27d01a510	Merge branch 'enh/addTtlToStream' into enh/rocksdbSstateMerge	2023-05-04 08:22:31 +00:00
Haojun Liao	3c61932ecc	refactor: do some internal refactor.	2023-05-01 19:28:54 +08:00
yihaoDeng	36a4413bf1	merge rocksdb inst	2023-04-27 14:38:33 +00:00
yihaoDeng	2d5218246d	add ttl to stream state key	2023-04-24 08:18:02 +00:00
yihaoDeng	3abdbec813	add ttl to stream state key	2023-04-24 08:17:57 +00:00
yihaoDeng	b640a0330d	change write opt	2023-04-19 23:55:09 +00:00
yihaoDeng	efa7b48c1b	Merge branch 'enh/rocksRevert' of https://github.com/taosdata/TDengine into enh/rocksRevert	2023-04-14 09:40:25 +00:00
yihaoDeng	4c70cfdfad	startGroupTableMe	2023-04-14 09:36:08 +00:00
Haojun Liao	5850a3ab01	Merge remote-tracking branch 'origin/enh/rocksRevert' into enh/rocksRevert	2023-04-14 10:37:17 +08:00
Haojun Liao	b57c813681	other: merge feature/3_liaohj	2023-04-14 10:36:54 +08:00
yihaoDeng	c0ebdb92d3	startGroupTableMe	2023-04-14 02:10:33 +00:00
yihaoDeng	36eef2fdef	refactor code	2023-04-13 09:57:04 +00:00
yihaoDeng	ed4aaade8c	add backend	2023-04-12 03:03:51 +00:00
yihaoDeng	ff8cb09f63	refactor backend	2023-04-11 10:47:15 +00:00
Haojun Liao	f5b52749c2	refactor: do some internal refactor.	2023-04-09 01:39:09 +08:00
yihaoDeng	c082536242	opt write snapshot	2023-04-07 07:26:15 +00:00
yihaoDeng	b701198dbb	add backend	2023-03-22 13:19:56 +00:00
Liu Jicong	3424b184d3	refactor(stream): distributed checkpoint	2022-12-02 03:48:45 +08:00
Liu Jicong	48894c8bdb	enh(stream): new api for stream queue	2022-11-25 18:03:40 +08:00
Liu Jicong	bc469f7f7b	fix(stream): delete tb should be checked in write thread	2022-11-08 11:30:29 +08:00
Liu Jicong	2fbc8e6306	refactor(stream): stream deploy and state transfer	2022-11-03 13:22:23 +08:00
Liu Jicong	5e253cc8ea	refactor(stream): fill history	2022-11-01 11:56:14 +08:00
Liu Jicong	75e5e490fd	refactor(stream): recover and fill history	2022-10-26 00:31:00 +08:00
Liu Jicong	853e6e2988	refactor(mnode): drop stream task	2022-08-17 19:19:58 +08:00
Liu Jicong	18f6fb6123	enh(tmq): speed up consumer recover	2022-08-10 16:04:03 +08:00
Liu Jicong	fc225a580d	enh(stream): recover process	2022-08-09 21:37:21 +08:00
Liu Jicong	a9d11b58ad	enh(stream): recover	2022-07-28 16:19:50 +08:00
Liu Jicong	3fa5791889	fix(stream): dispatch	2022-07-27 10:52:25 +08:00
jiacy-jcy	5200a48107	fix: update	2022-07-19 16:54:19 +08:00
Liu Jicong	280ed4f65d	feat(stream): pipelined exec for recovering	2022-07-15 21:29:53 +08:00
Liu Jicong	8a6e4b877a	refactor(stream): simple batch	2022-07-13 16:37:33 +08:00
Liu Jicong	8c5dbde918	refactor(stream): stream reader created in scanner	2022-07-06 14:20:07 +08:00
Liu Jicong	f2f5d68f3b	fix(stream): memory leak	2022-06-23 22:05:00 +08:00
Liu Jicong	fb596625d3	feat(stream): support retrieve	2022-06-22 19:12:31 +08:00
Liu Jicong	8eb08fa0d4	feat(stream): trigger mode add max delay	2022-06-15 16:11:20 +08:00
Liu Jicong	cbbf5f5d4d	refactor(stream)	2022-06-07 21:35:49 +08:00