chore: merge main #15
Closed
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
…#4705) * feat: cache each uncompressed page * chore: remove unused function * chore: log * chore: log * chore: row group pages cache kv * feat: also support row group level cache * chore: fix range count * feat: don't cache compressed page for row group cache * feat: use function to get part * chore: log whether scan is from compaction * chore: avoid get column * feat: add timer metrics * chore: Revert "feat: add timer metrics" This reverts commit 4618f57. * feat: don't cache individual uncompressed page * feat: append in row group level under append mode Signed-off-by: Ruihang Xia <waynestxia@gmail.com> * chore: fetch pages cost * perf: yield * Update src/mito2/src/sst/parquet/row_group.rs * refactor: cache key * feat: print file num and row groups num in explain * test: update sqlness test * chore: Update src/mito2/src/sst/parquet/page_reader.rs --------- Signed-off-by: Ruihang Xia <waynestxia@gmail.com> Co-authored-by: Ruihang Xia <waynestxia@gmail.com>
perf: remove `validate_request_with_table`
* chore: remove error:: * chore: avoid to use get_raw if unnecessary * chore: clearer method name * feat: remap node addresses in table route * chore: add unit test for remap address * feat: refresh node address mapping via heartbeat * feat: broadcast table cache invalidate on new epoch * chore: clarify heartbeat log * chore: remove InvalidHeartbeatRequest * chore: add log * feat: add role into NodeAddressKey * chore: fix test * Update src/common/meta/src/key/table_route.rs Co-authored-by: LFC <990479+MichaelScofield@users.noreply.github.com> * chore: simplify code --------- Co-authored-by: LFC <990479+MichaelScofield@users.noreply.github.com>
* fix: support append-only physical table Signed-off-by: Ruihang Xia <waynestxia@gmail.com> * Update src/metric-engine/src/engine/create.rs Co-authored-by: jeremyhi <jiachun_feng@proton.me> --------- Signed-off-by: Ruihang Xia <waynestxia@gmail.com> Co-authored-by: Weny Xu <wenymedia@gmail.com> Co-authored-by: jeremyhi <jiachun_feng@proton.me>
* feat(index): add `RangeReader` trait` Signed-off-by: Zhenchi <zhongzc_arch@outlook.com> * fix: return content_length as read bytes Signed-off-by: Zhenchi <zhongzc_arch@outlook.com> * chore: remove buffer & use `BufMut` Signed-off-by: Zhenchi <zhongzc_arch@outlook.com> --------- Signed-off-by: Zhenchi <zhongzc_arch@outlook.com>
* generic bundle trait * feat: impl get/let * fix: drop batch * test: tumble batch * feat: use batch eval flow * fix: div use arrow::div not mul * perf: not append batch * perf: use bool mask for reduce * perf: tiny opt * perf: refactor slow path * feat: opt if then * fix: WIP * perf: if then * chore: use trace instead * fix: reduce missing non-first batch * perf: flow if then using interleave * docs: add TODO * perf: remove unnecessary eq * chore: remove unused import * fix: run_available no longer loop forever * feat: blocking on high input buf * chore: increase threhold * chore: after rebase * chore: per review * chore: per review * fix: allow empty values in reduce&test * tests: more flow doc example tests * chore: per review * chore: per review
* feat: add respectiv get_by_path udf for json type * Apply review comments Co-authored-by: Weny Xu <wenymedia@gmail.com> * fix: fix compile error * refactor: change name of UDFs, add some tests --------- Co-authored-by: Weny Xu <wenymedia@gmail.com>
… of printing a warn log (GreptimeTeam#4709) * fix: pipeline dissert error is returned directly to the user, instead of printing a warn log * chore: add more test for pipeline
* chore: enable fuzz test for append table * fix: fix mysql translator
…d` (GreptimeTeam#4724) Signed-off-by: Zhenchi <zhongzc_arch@outlook.com>
…am#4723) * chore: add auto-decompression for http request * test: otlp
…ce `assert_eq` for long string compare (GreptimeTeam#4731) * fix: config test failed and use 'similar_asserts::assert_eq' to replace 'assert_eq' for long string compare * Update Cargo.toml Co-authored-by: Yingwen <realevenyag@gmail.com> * Update src/cmd/tests/load_config_test.rs Co-authored-by: Yingwen <realevenyag@gmail.com> --------- Co-authored-by: Ruihang Xia <waynestxia@gmail.com> Co-authored-by: Yingwen <realevenyag@gmail.com>
* feat: add respective json_is UDFs * refactor: rename to_json to parse_json * chore: happy clippy * chore: some rename * fix: small fixes
fix: correct `is_writable` behavior
* chore: version skew * fix: even more version skew * feat: use `ring` instead of `aws-lc` for remove nasm assembler on windows * feat: use `ring` for pgwire * feat: change to use `aws-lc-sys` on windows instead * feat: change back to use `ring` * chore: provide CryptoProvider * feat: use upstream repo * feat: install ring crypto lib in main * chore: use same fn to install in tests * feat: make pgwire use `ring`
…Team#4730) * feat: add an option to turn on compression for arrow output * fix: typo
* chore: cherrypick 52e8eeb * refactor/tables: Change variable from immutable to mutable in KvBackendCatalogManager's method * refactor/tables: Replace unbounded channel with bounded and use semaphore for concurrency control in KvBackendCatalogManager * refactor/tables: Add common-runtime dependency and update KvBackendCatalogManager to use common_runtime::spawn_global * refactor/tables: Await on sending error through channel in KvBackendCatalogManager
* chore: add log ingest interceptor * chore: rename * chore: update interceptor signature
* feat: improve support for postgres extended protocol * fix: lint fix * fix: test code * fix: adopt upstream * refactor: remove dup code * refactor: avoid copy on error message
* docs: json datatype rfc * docs: turn to a jsonb proposal * chore: fix typo * feat: add store and query process * fix: typo * fix: use query nodes instead of query plans * feat: a detailed overview of query * fix: grammar * fix: use independent cast function * fix: unify cast function * fix: refine, make statements clear * docs: update rfc according to impl * docs: refine * docs: fix wrong arrows * docs: refine * docs: fix some errors qaq
* chore(fuzz): print table name for debugging * chore: apply suggestions
* refactor: remove DfPlan wrapper Signed-off-by: Ruihang Xia <waynestxia@gmail.com> * clean up Signed-off-by: Ruihang Xia <waynestxia@gmail.com> * remove unused errors Signed-off-by: Ruihang Xia <waynestxia@gmail.com> * fix test assertion Signed-off-by: Ruihang Xia <waynestxia@gmail.com> --------- Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
* fix: don't prune fields in last non null mode * test: add sqlness test for field pruning * test: add flush * refine implementation Signed-off-by: Ruihang Xia <waynestxia@gmail.com> --------- Signed-off-by: Ruihang Xia <waynestxia@gmail.com> Co-authored-by: Ruihang Xia <waynestxia@gmail.com>
feat: use new image
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
I hereby agree to the terms of the GreptimeDB CLA
What's changed and what's your intention?
PLEASE DO NOT LEAVE THIS EMPTY !!!
Please explain IN DETAIL what the changes are in this PR and why they are needed:
Checklist
Refer to a related PR or issue link (optional)