Ning Sun
f293126315
feat: add logical plan based prepare statement for postgresql ( #1813 )
...
* feat: add logical plan based prepare statement for postgresql
* refactor: correct more types
* Update src/servers/src/postgres/types.rs
Co-authored-by: LFC <bayinamine@gmail.com >
* fix: address review issues
* test: add datetime in integration tests
---------
Co-authored-by: LFC <bayinamine@gmail.com >
2023-07-11 11:07:18 +08:00
Weny Xu
c615fb2a93
fix: fix uncaught error 🥲 ( #1929 )
...
fix: fix uncaught error
2023-07-10 23:41:20 +08:00
Yingwen
65f5349767
feat(mito2): Define basic structs for MitoEngine ( #1928 )
...
* chore: metadata wip
* docs(mito2): Add struct relationships
* feat(mito2): define basic structs
* feat: add version and refactor other metadata
* docs: remove generics param from MitoEngine
* chore: Update src/mito2/Cargo.toml
Co-authored-by: Lei, HUANG <6406592+v0y4g3r@users.noreply.github.com >
* chore: Apply suggestions from code review
Co-authored-by: Ruihang Xia <waynestxia@gmail.com >
---------
Co-authored-by: Lei, HUANG <6406592+v0y4g3r@users.noreply.github.com >
Co-authored-by: Ruihang Xia <waynestxia@gmail.com >
2023-07-10 12:25:33 +00:00
shuiyisong
04ddeffd2a
chore: add rate limit status code ( #1923 )
2023-07-10 17:41:59 +08:00
Weny Xu
c8ed1bbfae
fix: cast orc data against output schema ( #1922 )
...
fix: cast data against output schema
2023-07-10 08:53:38 +00:00
Lei, HUANG
207d3d23a1
chore: bump latest greptime-proto version ( #1920 )
2023-07-10 16:28:22 +08:00
shuiyisong
63173f63a1
chore: add interceptor for prometheus query ( #1919 )
...
* chore: add prom query interceptor
* chore: add test
* chore: add test
* chore: fix cr issue
2023-07-10 16:28:07 +08:00
Yingwen
4ea8a78817
feat: dedup rows while flushing memtables ( #1916 )
...
* test: enlarge meta client timeout
* feat: dedup on flush
* test: enlarge datanode clients timeout
* chore: fix typo
2023-07-10 15:07:10 +08:00
Lei, HUANG
553530cff4
fix: immediately reschedule a compaction after compaction ( #1882 )
...
* fix: immediately reschedule a compaction after compaction
* refactor: add WriterCompactRequest
* feat: reschedule compaction
* fix: only reschedule compaction when it's triggered by flush
* fix: remove max_files_in_l0
---------
Co-authored-by: evenyag <realevenyag@gmail.com >
2023-07-10 15:05:31 +08:00
Ruihang Xia
8e256b317d
test: add unit test for distributed limit pushdown ( #1917 )
...
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
2023-07-10 14:40:18 +08:00
Weny Xu
b31fad5d52
feat: switch to using create table procedure ( #1861 )
...
* feat: switch to using create table procedure
* fix: add missing table_id and fix uncaught error
* refactor: remove unused code and metrics
* chore: apply suggestions from CR
* chore: remove unused attributes
* feat: add info log and metrics
* fix: fix conflicts
2023-07-10 10:08:09 +08:00
Weny Xu
00181885cc
refactor: remove unused code ( #1913 )
2023-07-10 10:06:22 +08:00
Niwaka
195dfdc5d3
feat: add deregister_schema to CatalogManager ( #1911 )
...
* feat: add deregister_schema to CatalogManager
* refactor: MemoryCatalogManager::deregister_schema
* fix: typo
* fix: typo
2023-07-10 09:59:14 +08:00
Yingwen
f731193ddc
refactor: Define RegionId as a new type ( #1903 )
...
* refactor: Define RegionId as a new type
* chore: use into
* feat: custom debug print for region id
fix: test_show_create_table
2023-07-07 21:26:03 +08:00
LFC
f19498f73e
refactor: unify KvBackend and KvStore ( #1890 )
...
* refactor: unify KvBackend and KvStore
2023-07-07 19:53:49 +08:00
Weny Xu
6dd24f4dc4
feat!: rename WITH parameter ENDPOINT_URL to ENDPOINT ( #1904 )
...
* feat!: rename WITH parameter ENDPOINT_URL to ENDPOINT
* fix: typo
2023-07-07 17:04:24 +08:00
Weny Xu
64acfd3802
feat: implement drop table procedure ( #1872 )
...
* feat: implement drop table procedure
* fix: fix uncaught error
* refacotr: refactor error handling
* chore: apply suggestions from CR
* refactor: move fetch_table/s to table_routes.rs
* chore: fix clippy
* chore: apply suggestions from CR
* chore: rebase onto develop
* feat: compare the table_route value before deleting
* feat: handle if table already exists on datanode
* Update src/meta-srv/src/procedure/drop_table.rs
Co-authored-by: JeremyHi <jiachun_feng@proton.me >
---------
Co-authored-by: JeremyHi <jiachun_feng@proton.me >
2023-07-07 16:03:40 +08:00
Niwaka
8dcb12e317
feat: support where in show ( #1829 )
...
* feat: support where in show
* fix: lift schema out of match
* fix: rename
* fix: improve error handling
2023-07-07 13:45:54 +08:00
LFC
03e30652c8
refactor: TableNameKey and DatanodeTableKey ( #1868 )
...
* refactor: TableNameKey and DatanodeTableKey
2023-07-07 13:27:43 +08:00
Weny Xu
dc085442d7
chore: bump orc-rust to 0.2.4 ( #1894 )
...
chore: bump orc-rust to 0.2
2023-07-06 08:18:24 +00:00
Ruihang Xia
9153191819
fix: resolve catalog and schema in dist planner ( #1891 )
...
* try resolve catalog and schema
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix clippy
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* upload sqlness case
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix information schema case
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix unnamed table name
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix clippy
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
---------
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
2023-07-06 08:08:44 +00:00
Lei, HUANG
979400ac58
refactor: support special characters in table keys ( #1893 )
...
* refactor: support special characters in table keys
* remnove '"()
* Allow `:` as initial character of table names.
2023-07-06 15:17:08 +08:00
Weny Xu
28748edb0d
chore: bump proto to 917ead6 ( #1892 )
...
* feat: add table_id for ddl exprs
* chore: bump proto to 917ead6
2023-07-06 13:29:36 +08:00
Niwaka
66e5ed5483
feat: support gcs storage ( #1781 )
2023-07-05 23:03:51 +08:00
Weny Xu
4073fceea5
fix: fix broken CI 😢 ( #1884 )
2023-07-05 10:43:53 +08:00
Weny Xu
8a00424468
refactor: implement Display for TableRouteKey ( #1879 )
2023-07-05 09:42:16 +08:00
Weny Xu
ee16262b45
feat: add create table procedure ( #1845 )
...
* feat: add create table procedure
* feat: change table_info type from vec u8 to RawTableInfo
* feat: return create table status
* fix: fix uncaught error
* refactor: use a notifier to respond to callers
* chore: apply suggestions from CR
* chore: apply suggestions from CR
* chore: add comment
* chore: apply suggestions from CR
* refacotr: make CreateMetadata step after DatanodeCreateTable step
2023-07-04 22:24:43 +08:00
Yingwen
f37b394f1a
fix: check table existence in create table procedure ( #1880 )
...
* fix: check table existence in table procedures
* fix: use correct error variant
* chore: address view comments
* chore: address comments
* test: change error code
2023-07-04 22:01:27 +08:00
Eugene Tolbakov
ccee60f37d
feat(http_body_limit): add initial support for DefaultBodyLimit ( #1860 )
...
* feat(http_body_limit): add initial support for DefaultBodyLimit
* fix: address CR suggestions
* fix: adjust the const for default http body limit
* fix: adjust the toml_str for the test
* fix: address CR suggestions
* fix: body_limit units in example config toml files
* fix: address clippy suggestions
2023-07-04 20:56:56 +08:00
Weny Xu
000df8cf1e
feat: add ddl client ( #1856 )
...
* feat: add ddl client
* chore: apply suggestions from CR
* chore: apply suggestions from CR
2023-07-04 19:32:02 +08:00
Yingwen
884731a2c8
chore: initialize mito2 crate ( #1875 )
2023-07-04 17:55:00 +08:00
shuiyisong
2922c25a16
chore: stop caching None in CachedMetaKvBackend ( #1871 )
...
* chore: dont cache none
* fix: test case
* chore: add comment
* chore: minor rewrite
2023-07-04 17:17:48 +08:00
Lei, HUANG
3b6f70cde3
feat: initial twcs impl ( #1851 )
...
* feat: initial twcs impl
* chore: rename SimplePicker to LeveledPicker
* rename some structs
* Remove Compaction strategy
* make compaction picker a trait object
* make compaction picker configurable for every region
* chore: add some test for ttl
* add some tests
* fix: some style issues in cr
* feat: enable twcs when creating tables
* feat: allow config time window when creating tables
* fix: some cr comments
2023-07-04 16:42:27 +08:00
Yingwen
b8e92292d2
feat: Implement a new scan mode using a chain reader ( #1857 )
...
* feat: add log
* feat: print more info
* feat: use chain reader
* fix: panic on getting first range
* fix: prev not updated
* fix: reverse readers and iter backward
* chore: don't print windows in log
* feat: consider memtable range
Also fix the issue that using incorrect comparision method to sort time
ranges.
* fix: merge memtable window with sst's
* feat: add use_chain_reader option
* feat: skip empty memtables
* chore: change log level
* fix: memtable range not ordered
* style: fix clippy
* chore: address review comments
* chore: print region id in log
2023-07-04 16:01:34 +08:00
Ruihang Xia
746fe8b4fe
fix: use mark-deletion for system catalog ( #1874 )
...
* fix: use mark-deletion for system catalog
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix the default value
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* clean tables
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
---------
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
2023-07-04 16:00:39 +08:00
JeremyHi
20f2fc4a2a
feat: add leader kv store cache for metadata ( #1853 )
...
* feat: add leader kv store cache for metadata
* refactor: create cache internal
* fix: race condition
* fix: race condition on read
2023-07-04 15:49:42 +08:00
Yingwen
2ef84f64f1
feat(servers): enlarge default body limit to 64M ( #1873 )
2023-07-04 07:13:14 +00:00
fys
451cc02d8d
chore: add feature for metrics-process, default enable ( #1870 )
...
chore: add feature for metrics process, default enable
2023-07-04 13:28:33 +08:00
LFC
5b42e15105
refactor: add TableInfoKey and TableRegionKey ( #1865 )
...
* refactor: add TableInfoKey and TableRegionKey
* refactor: move KvBackend to common-meta
* fix: resolve PR comments
2023-07-03 18:01:20 +08:00
shuiyisong
e1bb7acfe5
fix: return err msg if use wrong database in MySQL ( #1866 )
2023-07-03 17:31:09 +08:00
Cao Zhengjia
e54415e723
feat: Make heartbeat intervals configurable in Frontend and Datanode ( #1864 )
...
* update frontend options and config
* fix format
2023-07-03 12:08:47 +08:00
Vanish
563f6e05e2
feat: remove all the manifests in drop_region. ( #1834 )
...
* feat: drop_region delete manifest file
* chore: remove redundant code
* chore: fmt
* chore: clippy
* chore: clippy
* feat: support delete_all in manifest.
* chore:CR
* test: test_drop_basic, test_drop_reopen
* chore: cr
* fix: typo
* chore: cr
2023-06-30 17:42:11 +08:00
Ruihang Xia
c77b94650c
refactor: remove Table::scan method ( #1855 )
...
* remove scan method
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* clean up
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
---------
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
2023-06-30 12:13:14 +08:00
Ruihang Xia
605776f49c
feat: support bool operator with other computation ( #1844 )
...
* add some cases
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix sqlness test
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* impl atan2 and power
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix instant manipulator
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix clippy
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
---------
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
2023-06-29 19:23:54 +08:00
Ruihang Xia
d45e7b7480
refactor: build parquet file stream from ParquetExec ( #1852 )
...
* refactor: build parquet file stream from ParquetExec
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* rename sqlness case
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
---------
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
2023-06-29 19:19:31 +08:00
JeremyHi
2b3ca1309a
feat: table_routes util ( #1849 )
2023-06-29 16:47:56 +08:00
Weny Xu
acfa229641
chore: bump orc-rust to 0319acd ( #1847 )
2023-06-29 10:45:05 +08:00
JeremyHi
7e23dd7714
feat: http api for node-lease ( #1843 )
...
* feat: add node-lease http api
* revert: show_create.result
2023-06-29 09:34:54 +08:00
Lei, HUANG
559d1f73a2
feat: push all possible filters down to parquet exec ( #1839 )
...
* feat: push all possible filters down to parquet exec
* fix: project
* test: add ut for DatafusionArrowPredicate
* fix: according to CR comments
2023-06-28 20:14:37 +08:00
JeremyHi
bc33fdc8ef
feat: save node lease into memory ( #1841 )
...
* feat: lease secs = 5
* feat: set lease data into memory of leader
* fix: ignore stale heartbeat
* Update src/meta-srv/src/election.rs
Co-authored-by: LFC <bayinamine@gmail.com >
---------
Co-authored-by: LFC <bayinamine@gmail.com >
2023-06-28 11:54:06 +08:00