Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Feature] Trino dialect supports insert into syntax #52650

Closed
wants to merge 701 commits into from

Conversation

renzhimin7
Copy link
Contributor

@renzhimin7 renzhimin7 commented Nov 5, 2024

Why I'm doing:

CREATE TABLE t3 (
    day int)
    PROPERTIES (
"replication_num" = "1"
);

set sql_dialect='trino';
select doy(date '2022-03-06');
+-------------------------+
| dayofyear('2022-03-06') |
+-------------------------+
|                      65 |
+-------------------------+
1 row in set (0.04 sec)

insert into t3 select doy(date '2022-03-06');
ERROR 1064 (HY000): Getting analyzing error from line 1, column 22 to line 1, column 43. Detail message: No matching function with signature: doy(date)

What I'm doing:

Fixes #52665

What type of PR is this:

  • BugFix
  • Feature
  • Enhancement
  • Refactor
  • UT
  • Doc
  • Tool

Does this PR entail a change in behavior?

  • Yes, this PR will result in a change in behavior.
  • No, this PR will not result in a change in behavior.

If yes, please specify the type of change:

  • Interface/UI changes: syntax, type conversion, expression evaluation, display information
  • Parameter changes: default values, similar parameters but with different default values
  • Policy changes: use new policy to replace old one, functionality automatically enabled
  • Feature removed
  • Miscellaneous: upgrade & downgrade compatibility, etc.

Checklist:

  • I have added test cases for my bug fix or my new feature
  • This pr needs user documentation (for new or modified features or behaviors)
  • I have added documentation for my new feature or new function
  • This is a backport pr

Bugfix cherry-pick branch check:

  • I have checked the version labels which the pr will be auto-backported to the target branch
    • 3.3
    • 3.2
    • 3.1
    • 3.0
    • 2.5

@renzhimin7 renzhimin7 requested a review from a team as a code owner November 5, 2024 15:22
@renzhimin7 renzhimin7 changed the title Trino dialect supports insert syntax [Feature] Trino dialect supports insert syntax Nov 5, 2024
Youngwb
Youngwb previously approved these changes Nov 6, 2024
dirtysalt
dirtysalt previously approved these changes Nov 6, 2024
@dirtysalt dirtysalt enabled auto-merge (squash) November 6, 2024 02:09
@renzhimin7 renzhimin7 changed the title [Feature] Trino dialect supports insert syntax [Feature] Trino dialect supports insert syntax #52665 Nov 6, 2024
@renzhimin7 renzhimin7 changed the title [Feature] Trino dialect supports insert syntax #52665 [Feature] Trino dialect supports insert syntax Nov 6, 2024
auto-merge was automatically disabled November 7, 2024 07:49

Head branch was pushed to by a user without write access

@renzhimin7 renzhimin7 dismissed stale reviews from dirtysalt and Youngwb via a8d0413 November 7, 2024 07:49
@trueeyu
Copy link
Contributor

trueeyu commented Nov 7, 2024

https://github.com/Mergifyio rebase main

Copy link
Contributor

mergify bot commented Nov 7, 2024

rebase main

✅ Branch has been successfully rebased

@renzhimin7 renzhimin7 changed the title [Feature] Trino dialect supports insert syntax [Feature] Trino dialect supports insert into syntax Nov 7, 2024
@miomiocat miomiocat enabled auto-merge (squash) November 7, 2024 11:23
Copy link

sonarcloud bot commented Nov 7, 2024

xiangguangyxg and others added 7 commits November 7, 2024 20:21
…n shared-data mode (StarRocks#51837)

## Why I'm doing:
The physical partition is wrong than sub partitions are missed in fast schema evolution in shared-data mode.

## What I'm doing:
Fix wrong physical partition in fast schema evolution in shared-data mode

Fixes StarRocks#51745

Signed-off-by: xiangguangyxg <[email protected]>
Signed-off-by: zhiminr.ren <[email protected]>
zombee0 and others added 9 commits November 7, 2024 20:21
Fix redundant variable definition in CatalogMgr

Signed-off-by: IHEII <[email protected]>
Signed-off-by: zhiminr.ren <[email protected]>
auto-merge was automatically disabled November 7, 2024 12:40

Head branch was pushed to by a user without write access

@renzhimin7 renzhimin7 requested review from a team as code owners November 7, 2024 12:40
@github-actions github-actions bot added documentation Improvements or additions to documentation labels Nov 7, 2024
@renzhimin7 renzhimin7 closed this Nov 7, 2024
Copy link

github-actions bot commented Nov 7, 2024

[FE Incremental Coverage Report]

pass : 5 / 5 (100.00%)

file detail

path covered_line new_line coverage not_covered_line_detail
🔵 com/starrocks/connector/parser/trino/AstBuilder.java 5 5 100.00% []

Copy link

github-actions bot commented Nov 7, 2024

[Java-Extensions Incremental Coverage Report]

pass : 0 / 0 (0%)

Copy link

github-actions bot commented Nov 7, 2024

[BE Incremental Coverage Report]

fail : 1767 / 3836 (46.06%)

file detail

path covered_line new_line coverage not_covered_line_detail
🔵 src/exec/tablet_sink_index_channel.cpp 0 38 00.00% [418, 423, 424, 425, 426, 430, 440, 502, 515, 524, 570, 572, 573, 574, 577, 578, 580, 581, 582, 583, 584, 585, 587, 588, 589, 590, 592, 593, 594, 597, 599, 602, 605, 606, 618, 698, 717, 720]
🔵 src/storage/delta_writer.cpp 0 5 00.00% [311, 505, 562, 587, 606]
🔵 src/runtime/plan_fragment_executor.cpp 0 4 00.00% [83, 84, 85, 149]
🔵 src/storage/vertical_compaction_task.cpp 0 1 00.00% [141]
🔵 src/agent/publish_version.cpp 0 1 00.00% [161]
🔵 src/storage/meta_reader.cpp 0 35 00.00% [37, 119, 127, 133, 188, 189, 190, 191, 192, 227, 231, 234, 235, 238, 245, 246, 250, 252, 254, 255, 256, 258, 259, 261, 262, 264, 265, 266, 267, 270, 271, 272, 273, 280, 281]
🔵 src/exec/pipeline/hashjoin/spillable_hash_join_build_operator.cpp 0 6 00.00% [252, 254, 257, 258, 261, 267]
🔵 src/runtime/routine_load/data_consumer_group.cpp 0 4 00.00% [91, 104, 309, 322]
🔵 src/runtime/query_statistics.h 0 2 00.00% [57, 58]
🔵 src/runtime/local_pass_through_buffer.h 0 1 00.00% [36]
🔵 src/exec/mysql_scanner.cpp 0 18 00.00% [77, 167, 169, 171, 176, 177, 179, 181, 182, 183, 184, 185, 188, 189, 190, 192, 193, 195]
🔵 src/exprs/cast_expr.cpp 0 1 00.00% [1127]
🔵 src/exec/hash_joiner.cpp 0 5 00.00% [60, 91, 92, 95, 256]
🔵 src/exprs/agg/count.h 0 1 00.00% [182]
🔵 src/storage/rowset/segment_options.cpp 0 1 00.00% [66]
🔵 src/column/array_column.h 0 1 00.00% [176]
🔵 src/exec/cross_join_node.cpp 0 5 00.00% [77, 78, 626, 627, 628]
🔵 src/storage/olap_server.cpp 0 1 00.00% [120]
🔵 src/storage/segment_replicate_executor.cpp 0 3 00.00% [96, 114, 130]
🔵 src/exec/pipeline/scan/scan_operator.h 0 1 00.00% [99]
🔵 src/agent/utils.cpp 0 10 00.00% [54, 55, 56, 58, 61, 72, 73, 74, 76, 79]
🔵 src/exec/schema_scanner.cpp 0 1 00.00% [107]
🔵 src/exprs/agg/hll_union.h 0 5 00.00% [35, 37, 38, 44, 60]
🔵 src/agent/task_worker_pool.cpp 0 10 00.00% [189, 526, 527, 557, 558, 559, 576, 577, 716, 756]
🔵 src/exec/schema_scanner/schema_tasks_scanner.cpp 0 2 00.00% [33, 67]
🔵 src/exec/olap_scan_prepare.cpp 0 4 00.00% [359, 360, 418, 424]
🔵 src/exprs/expr.h 0 1 00.00% [124]
🔵 src/http/default_path_handlers.cpp 0 3 00.00% [152, 153, 154]
🔵 src/exec/schema_scanner/schema_views_scanner.cpp 0 1 00.00% [38]
🔵 src/exec/pipeline/scan/connector_scan_operator.cpp 0 2 00.00% [300, 301]
🔵 src/exec/es/es_scan_reader.cpp 0 1 00.00% [140]
🔵 src/exec/pipeline/sink/export_sink_operator.cpp 0 1 00.00% [152]
🔵 src/storage/task/engine_clone_task.cpp 0 2 00.00% [170, 619]
🔵 src/exec/schema_scanner/schema_be_logs_scanner.cpp 0 1 00.00% [51]
🔵 src/exprs/decimal_binary_function.h 0 1 00.00% [221]
🔵 src/common/greplog.cpp 0 6 00.00% [37, 38, 186, 261, 262, 265]
🔵 src/exec/pipeline/nljoin/nljoin_probe_operator.cpp 0 1 00.00% [551]
🔵 src/exec/hash_join_components.h 0 1 00.00% [56]
🔵 src/storage/delta_column_group.h 0 6 00.00% [72, 73, 74, 75, 76, 77]
🔵 src/exec/pipeline/sort/partition_sort_sink_operator.cpp 0 1 00.00% [79]
🔵 src/exec/olap_utils.h 0 1 00.00% [102]
🔵 src/runtime/local_pass_through_buffer.cpp 0 1 00.00% [44]
🔵 src/gutil/strings/split.cc 0 3 00.00% [889, 898, 909]
🔵 src/runtime/buffer_control_block.h 0 2 00.00% [103, 104]
🔵 src/exprs/array_functions.tpp 0 177 00.00% [54, 262, 263, 265, 277, 278, 279, 280, 281, 282, 285, 286, 287, 288, 289, 290, 292, 293, 295, 296, 297, 298, 300, 304, 305, 306, 307, 308, 311, 312, 319, 321, 324, 325, 327, 328, 330, 336, 337, 338, 339, 340, 341, 342, 345, 347, 348, 353, 365, 373, 379, 380, 388, 389, 393, 396, 399, 402, 412, 417, 419, 422, 423, 424, 425, 426, 427, 433, 434, 435, 439, 441, 445, 446, 448, 449, 450, 451, 452, 454, 455, 457, 460, 461, 462, 463, 466, 470, 472, 476, 477, 478, 479, 481, 486, 487, 489, 509, 522, 724, 998, 1004, 1005, 1006, 1044, 1057, 1058, 1059, 1063, 1065, 1066, 1067, 1069, 1071, 1073, 1075, 1077, 1081, 1083, 1084, 1085, 1086, 1087, 1088, 1092, 1093, 1096, 1099, 1106, 1110, 1111, 1113, 1114, 1115, 1116, 1117, 1118, 1120, 1122, 1123, 1124, 1127, 1128, 1133, 1135, 1136, 1137, 1138, 1139, 1140, 1142, 1143, 1144, 1145, 1148, 1155, 1169, 1171, 1172, 1173, 1175, 1176, 1178, 1179, 1180, 1182, 1183, 1184, 1185, 1188, 1189, 1192, 1194, 1196, 1199, 1200, 1203]
🔵 src/exprs/table_function/list_rowsets.cpp 0 1 00.00% [77]
🔵 src/column/fixed_length_column_base.h 0 3 00.00% [240, 241, 242]
🔵 src/exec/pipeline/hashjoin/spillable_hash_join_probe_operator.cpp 0 1 00.00% [321]
🔵 src/column/object_column.h 0 4 00.00% [217, 219, 222, 231]
🔵 src/exprs/agg/hll_union_count.h 0 3 00.00% [40, 43, 65]
🔵 src/exec/hash_join_components.cpp 0 10 00.00% [22, 23, 24, 30, 31, 32, 33, 42, 46, 49]
🔵 src/exec/hash_join_node.cpp 0 3 00.00% [148, 150, 209]
🔵 src/storage/compaction_manager.h 0 1 00.00% [99]
🔵 src/column/adaptive_nullable_column.h 0 2 00.00% [279, 559]
🔵 src/script/script.cpp 0 18 00.00% [179, 180, 215, 300, 301, 302, 303, 305, 308, 309, 310, 311, 380, 383, 384, 387, 388, 389]
🔵 src/exec/pipeline/aggregate/spillable_aggregate_distinct_blocking_operator.cpp 0 1 00.00% [185]
🔵 src/exprs/function_context.cpp 0 1 00.00% [200]
🔵 src/udf/java/java_data_converter.cpp 0 30 00.00% [167, 216, 229, 230, 231, 232, 233, 234, 242, 243, 244, 245, 246, 247, 248, 249, 251, 252, 255, 257, 258, 259, 260, 261, 262, 263, 264, 266, 269, 270]
🔵 src/runtime/snapshot_loader.cpp 0 21 00.00% [91, 186, 192, 195, 197, 198, 199, 202, 203, 205, 206, 209, 214, 215, 239, 385, 386, 432, 442, 580, 861]
🔵 src/exec/schema_scan_node.cpp 0 1 00.00% [185]
🔵 src/exec/spill/spiller.hpp 0 1 00.00% [190]
🔵 src/exprs/lambda_function.h 0 4 00.00% [50, 51, 56, 57]
🔵 src/exec/hash_joiner.h 0 4 00.00% [93, 94, 287, 288]
🔵 src/http/action/pprof_actions.cpp 0 1 00.00% [165]
🔵 src/util/runtime_profile.cpp 0 9 00.00% [752, 771, 773, 777, 779, 780, 782, 783, 786]
🔵 src/io/s3_input_stream.h 0 3 00.00% [30, 31, 33]
🔵 src/udf/java/java_udf.cpp 0 2 00.00% [410, 413]
🔵 src/exec/join_hash_map.h 0 1 00.00% [283]
🔵 src/column/column.h 0 6 00.00% [100, 172, 208, 234, 239, 241]
🔵 src/column/json_column.cpp 0 2 00.00% [27, 77]
🔵 src/exprs/agg/percentile_union.h 0 4 00.00% [28, 31, 36, 44]
🔵 src/exec/pipeline/hashjoin/hash_join_probe_operator.cpp 0 10 00.00% [127, 128, 129, 131, 132, 134, 135, 138, 139, 140]
🔵 src/column/column_builder.h 0 1 00.00% [60]
🔵 src/connector/lake_connector.cpp 0 4 00.00% [350, 351, 497, 498]
🔵 src/agent/heartbeat_server.cpp 0 9 00.00% [98, 104, 109, 156, 157, 160, 161, 164, 165]
🔵 src/exec/schema_scanner/schema_materialized_views_scanner.cpp 0 2 00.00% [63, 122]
🔵 src/exec/connector_scan_node.cpp 0 1 00.00% [451]
🔵 src/exec/sorted_streaming_aggregator.cpp 0 7 00.00% [169, 218, 330, 377, 394, 413, 442]
🔵 src/runtime/local_tablets_channel.cpp 0 18 00.00% [109, 110, 111, 112, 113, 115, 270, 503, 557, 593, 674, 718, 721, 724, 725, 726, 727, 772]
🔵 src/exec/aggregate/aggregate_base_node.cpp 0 11 00.00% [71, 73, 76, 77, 79, 80, 81, 82, 83, 84, 86]
🔵 src/agent/finish_task.cpp 0 1 00.00% [35]
🔵 src/storage/olap_meta_reader.cpp 0 1 00.00% [93]
🔵 src/storage/rowset/array_column_writer.cpp 0 2 00.00% [75, 76]
🔵 src/column/map_column.h 0 2 00.00% [167, 168]
🔵 src/exec/pipeline/fragment_executor.cpp 0 57 00.00% [145, 147, 184, 189, 239, 240, 241, 242, 243, 372, 374, 375, 376, 377, 378, 379, 381, 382, 383, 384, 385, 386, 387, 388, 389, 396, 397, 400, 404, 405, 408, 409, 410, 411, 412, 417, 418, 486, 487, 548, 549, 552, 558, 664, 799, 898, 917, 918, 919, 920, 921, 923, 924, 925, 928, 931, 937]
🔵 src/fs/fs.h 0 2 00.00% [59, 160]
🔵 src/http/action/pipeline_blocking_drivers_action.cpp 0 2 00.00% [164, 166]
🔵 src/runtime/types.h 0 2 00.00% [81, 83]
🔵 src/util/dynamic_cache.h 0 1 00.00% [190]
🔵 src/exec/orc_scanner.cpp 0 2 00.00% [89, 90]
🔵 src/agent/agent_task.cpp 0 28 00.00% [88, 275, 438, 445, 453, 511, 556, 558, 561, 562, 563, 565, 566, 567, 569, 570, 571, 572, 573, 574, 575, 576, 577, 655, 661, 689, 695, 725]
🔵 src/util/thrift_rpc_helper.cpp 0 10 00.00% [63, 66, 67, 68, 70, 76, 77, 78, 79, 81]
🔵 src/exprs/agg/bitmap_agg.h 0 1 00.00% [41]
🔵 src/exec/pipeline/scan/olap_chunk_source.cpp 0 43 00.00% [81, 84, 85, 86, 105, 106, 107, 108, 109, 110, 111, 112, 113, 114, 115, 116, 117, 118, 154, 158, 170, 171, 246, 247, 248, 251, 254, 255, 256, 257, 258, 259, 260, 261, 322, 323, 325, 328, 329, 330, 354, 357, 359]
🔵 src/exec/aggregate/agg_hash_map.h 0 3 00.00% [572, 676, 838]
🔵 src/io/s3_input_stream.cpp 0 27 00.00% [45, 46, 47, 48, 50, 51, 52, 53, 54, 55, 57, 61, 62, 63, 64, 67, 68, 71, 72, 73, 74, 75, 78, 80, 83, 86, 87]
🔵 src/column/adaptive_nullable_column.cpp 0 14 00.00% [148, 149, 153, 154, 158, 159, 165, 166, 173, 174, 185, 186, 195, 196]
🔵 src/column/binary_column.h 0 1 00.00% [175]
🔵 src/exec/iceberg/iceberg_delete_builder.h 0 4 00.00% [28, 37, 38, 39]
🔵 src/runtime/mysql_result_writer.cpp 0 2 00.00% [53, 133]
🔵 src/runtime/result_writer.h 0 4 00.00% [68, 69, 72, 73]
🔵 src/exprs/function_helper.h 0 4 00.00% [45, 46, 47, 49]
🔵 src/exec/schema_scanner/schema_be_threads_scanner.cpp 0 3 00.00% [57, 99, 103]
🔵 src/fs/fs_s3.cpp 0 53 00.00% [78, 79, 131, 136, 138, 150, 209, 210, 211, 212, 247, 248, 260, 281, 282, 300, 302, 305, 306, 307, 308, 309, 310, 383, 391, 392, 398, 407, 409, 410, 411, 413, 414, 415, 430, 522, 523, 524, 525, 526, 527, 528, 529, 530, 531, 532, 542, 544, 555, 556, 571, 572, 574]
🔵 src/exec/schema_scanner/schema_variables_scanner.cpp 0 1 00.00% [62]
🔵 src/http/action/stop_be_action.cpp 0 1 00.00% [41]
🔵 src/runtime/global_dict/miscs.cpp 0 1 00.00% [43]
🔵 src/http/action/greplog_action.cpp 0 1 00.00% [69]
🔵 src/exec/aggregate/agg_hash_set.h 0 8 00.00% [268, 301, 346, 372, 384, 385, 466, 487]
🔵 src/exprs/agg/hll_ndv.h 0 6 00.00% [45, 48, 49, 81, 91, 102]
🔵 src/runtime/global_dict/parser.cpp 0 1 00.00% [205]
🔵 src/column/const_column.h 0 1 00.00% [54]
🔵 src/column/object_column.cpp 0 2 00.00% [114, 115]
🔵 src/runtime/broker_mgr.cpp 0 5 00.00% [85, 87, 88, 89, 90]
🔵 src/storage/compaction_task.h 0 1 00.00% [243]
🔵 src/exprs/arithmetic_operation.h 0 1 00.00% [372]
🔵 src/exec/olap_scan_node.cpp 0 10 00.00% [271, 406, 407, 580, 581, 582, 583, 584, 585, 732]
🔵 src/exprs/table_function/java_udtf_function.cpp 0 17 00.00% [147, 148, 149, 151, 152, 153, 154, 156, 157, 160, 162, 171, 172, 174, 175, 198, 201]
🔵 src/exprs/array_functions.h 0 14 00.00% [35, 36, 40, 41, 47, 48, 52, 53, 57, 58, 81, 82, 86, 87]
🔵 src/exec/spill/spill_components.cpp 0 3 00.00% [333, 334, 335]
🔵 src/storage/olap_runtime_range_pruner.hpp 0 1 00.00% [90]
🔵 src/exec/pipeline/result_sink_operator.cpp 0 8 00.00% [34, 40, 43, 46, 49, 59, 109, 137]
🔵 src/agent/report_task.cpp 0 1 00.00% [23]
🔵 src/service/service_be/internal_service.cpp 0 15 00.00% [101, 102, 103, 104, 109, 114, 121, 125, 126, 130, 134, 135, 139, 143, 144]
🔵 src/exec/topn_node.cpp 0 1 00.00% [376]
🔵 src/storage/data_dir.cpp 0 2 00.00% [402, 421]
🔵 src/service/internal_service.cpp 0 11 00.00% [298, 330, 331, 332, 334, 335, 430, 431, 434, 544, 545]
🔵 src/http/action/update_config_action.cpp 0 46 00.00% [82, 85, 87, 91, 93, 101, 103, 108, 110, 111, 112, 114, 115, 123, 125, 126, 130, 131, 132, 133, 134, 137, 139, 141, 143, 145, 146, 147, 148, 150, 157, 159, 166, 168, 169, 172, 175, 177, 179, 184, 186, 189, 190, 191, 193, 194]
🔵 src/exec/pipeline/olap_table_sink_operator.cpp 0 1 00.00% [109]
🔵 src/runtime/statistic_result_writer.cpp 0 36 00.00% [36, 41, 55, 59, 79, 132, 133, 147, 149, 370, 371, 372, 373, 374, 375, 377, 378, 380, 381, 382, 383, 384, 385, 386, 387, 388, 389, 392, 393, 395, 396, 397, 399, 402, 403, 404]
🔵 src/exprs/java_function_call_expr.cpp 0 1 00.00% [139]
🔵 src/exec/schema_scanner/schema_be_cloud_native_compactions_scanner.cpp 0 13 00.00% [72, 78, 83, 88, 93, 103, 119, 130, 141, 142, 143, 145, 146]
🔵 src/common/daemon.cpp 0 52 00.00% [158, 164, 165, 174, 176, 180, 181, 182, 183, 184, 185, 187, 191, 192, 193, 194, 195, 196, 197, 198, 200, 201, 202, 203, 204, 206, 207, 208, 209, 212, 215, 216, 217, 220, 221, 222, 223, 224, 225, 226, 227, 229, 232, 233, 234, 235, 237, 238, 239, 243, 245, 246]
🔵 src/exprs/column_ref.cpp 0 2 00.00% [34, 35]
🔵 src/connector/mysql_connector.cpp 0 2 00.00% [62, 220]
🔵 src/exec/pipeline/aggregate/spillable_aggregate_blocking_source_operator.cpp 0 1 00.00% [27]
🔵 src/service/service_be/starrocks_be.cpp 0 5 00.00% [100, 105, 169, 179, 181]
🔵 src/exprs/agg/aggregate.h 0 4 00.00% [325, 347, 363, 387]
🔵 src/runtime/current_thread.h 0 2 00.00% [66, 137]
🔵 src/exprs/agg/window.h 0 50 00.00% [514, 524, 525, 526, 527, 529, 530, 534, 564, 565, 568, 578, 596, 597, 599, 602, 603, 604, 605, 606, 609, 610, 611, 612, 613, 614, 616, 621, 623, 626, 645, 646, 647, 648, 649, 651, 652, 653, 654, 661, 662, 664, 678, 679, 681, 684, 686, 687, 688, 689]
🔵 src/exprs/agg/percentile_approx.h 0 6 00.00% [54, 55, 56, 60, 85, 89]
🔵 src/exec/tablet_sink.cpp 0 1 00.00% [421]
🔵 src/runtime/fragment_mgr.cpp 0 10 00.00% [310, 311, 315, 710, 711, 713, 714, 715, 717, 822]
🔵 src/runtime/query_statistics.cpp 0 20 00.00% [58, 59, 60, 61, 62, 63, 64, 110, 111, 112, 115, 117, 118, 120, 121, 122, 134, 135, 136, 137]
🔵 src/service/backend_options.cpp 0 4 00.00% [41, 42, 44, 45]
🔵 src/column/column_access_path.cpp 0 1 00.00% [35]
🔵 src/runtime/variable_result_writer.cpp 0 2 00.00% [31, 44]
🔵 src/exprs/agg/java_udaf_function.h 0 1 00.00% [217]
🔵 src/exec/pipeline/hash_partition_context.cpp 0 1 00.00% [40]
🔵 src/exec/analytor.cpp 0 7 00.00% [200, 216, 218, 219, 220, 601, 608]
🔵 src/exec/join_hash_map.tpp 0 13 00.00% [1032, 1055, 1058, 1059, 1060, 1061, 1062, 1063, 1066, 1067, 1068, 1069, 1070]
🔵 src/runtime/lake_snapshot_loader.cpp 0 2 00.00% [85, 120]
🔵 src/fs/hdfs/fs_hdfs.cpp 0 2 00.00% [40, 66]
🔵 src/exec/pipeline/sink/memory_scratch_sink_operator.cpp 0 1 00.00% [51]
🔵 src/exprs/expr.cpp 1 9 11.11% [81, 82, 83, 84, 85, 86, 87, 88]
🔵 src/exprs/agg/maxmin_by.h 24 160 15.00% [39, 56, 70, 71, 72, 73, 74, 85, 86, 87, 90, 91, 92, 93, 94, 112, 113, 122, 123, 124, 125, 126, 129, 130, 131, 132, 133, 145, 146, 159, 160, 161, 162, 178, 179, 180, 181, 182, 183, 184, 201, 202, 203, 204, 205, 206, 207, 218, 219, 239, 240, 244, 251, 268, 277, 278, 279, 280, 281, 283, 284, 285, 286, 288, 289, 292, 293, 297, 302, 304, 307, 308, 309, 310, 312, 313, 314, 325, 326, 327, 328, 329, 330, 332, 333, 336, 337, 338, 339, 341, 345, 355, 360, 385, 399, 400, 402, 403, 408, 409, 410, 411, 412, 413, 414, 415, 418, 421, 423, 424, 425, 426, 428, 436, 439, 440, 441, 442, 444, 445, 448, 453, 455, 456, 457, 458, 460, 463, 481, 482, 483, 484, 493, 496, 498, 514]
🔵 src/exprs/runtime_filter_bank.cpp 2 12 16.67% [129, 646, 647, 651, 652, 653, 654, 675, 676, 677]
🔵 src/runtime/exec_env.h 1 6 16.67% [248, 255, 277, 278, 279]
🔵 src/util/cpu_info.cpp 2 12 16.67% [243, 244, 249, 250, 252, 255, 270, 271, 272, 274]
🔵 src/storage/column_in_predicate.cpp 7 39 17.95% [371, 373, 375, 376, 383, 385, 386, 388, 390, 391, 393, 395, 396, 402, 404, 405, 407, 409, 410, 412, 414, 415, 417, 419, 420, 422, 424, 425, 427, 429, 430, 432]
🔵 src/exec/pipeline/exec_state_reporter.cpp 2 11 18.18% [27, 156, 157, 163, 278, 279, 280, 281, 282]
🔵 src/storage/compaction_manager.cpp 3 15 20.00% [60, 215, 217, 219, 220, 221, 222, 224, 225, 226, 227, 275]
🔵 src/column/column_helper.cpp 2 8 25.00% [444, 445, 446, 447, 448, 449]
🔵 src/exprs/arithmetic_expr.cpp 1 4 25.00% [37, 204, 205]
🔵 src/exec/pipeline/scan/morsel.cpp 13 46 28.26% [38, 46, 47, 48, 49, 51, 58, 59, 67, 83, 86, 87, 90, 124, 126, 129, 130, 134, 135, 136, 137, 139, 140, 141, 167, 170, 171, 172, 173, 175, 176, 207, 208]
🔵 src/column/field.h 4 12 33.33% [45, 46, 49, 50, 51, 52, 53, 54]
🔵 src/exec/pipeline/stream_epoch_manager.cpp 1 3 33.33% [200, 201]
🔵 src/storage/rowset/map_column_writer.cpp 1 3 33.33% [77, 98]
🔵 src/storage/chunk_helper.cpp 8 22 36.36% [236, 237, 240, 241, 242, 250, 252, 271, 278, 537, 544, 545, 548, 549]
🔵 src/storage/tablet.cpp 8 21 38.10% [163, 164, 630, 631, 632, 635, 636, 644, 645, 646, 649, 878, 925]
🔵 src/exec/aggregator.h 2 5 40.00% [512, 578, 579]
🔵 src/runtime/buffer_control_block.cpp 6 15 40.00% [169, 172, 174, 175, 194, 195, 197, 198, 200]
🔵 src/storage/metadata_util.cpp 2 5 40.00% [68, 217, 218]
🔵 src/exec/hdfs_scanner_parquet.cpp 3 7 42.86% [30, 31, 32, 33]
🔵 src/exec/pipeline/fragment_context.cpp 3 7 42.86% [168, 196, 197, 262]
🔵 src/storage/rowset/rowset_writer.cpp 22 47 46.81% [174, 175, 181, 182, 573, 682, 683, 686, 704, 709, 765, 766, 767, 768, 769, 770, 771, 772, 773, 774, 775, 778, 780, 781, 782]
🔵 src/storage/rowset/binary_prefix_page.cpp 2 4 50.00% [307, 313]
🔵 src/exprs/map_apply_expr.cpp 1 2 50.00% [116]
🔵 src/column/fixed_length_column_base.cpp 1 2 50.00% [33]
🔵 src/storage/schema_change.cpp 1 2 50.00% [196]
🔵 src/column/struct_column.cpp 1 2 50.00% [450]
🔵 src/formats/orc/apache-orc/c++/src/sargs/PredicateLeaf.cc 1 2 50.00% [709]
🔵 src/exprs/function_context.h 1 2 50.00% [156]
🔵 src/exec/pipeline/scan/morsel.h 4 8 50.00% [268, 269, 270, 367]
🔵 src/exec/workgroup/scan_executor.cpp 2 4 50.00% [43, 44]
🔵 src/util/thrift_client.cpp 1 2 50.00% [37]
🔵 src/runtime/descriptors.h 1 2 50.00% [215]
🔵 src/exec/pipeline/pipeline_driver_executor.h 2 4 50.00% [40, 41]
🔵 src/storage/tablet_reader.cpp 1 2 50.00% [363]
🔵 src/storage/segment_flush_executor.cpp 1 2 50.00% [58]
🔵 src/column/chunk.cpp 3 6 50.00% [139, 140, 141]
🔵 src/exprs/binary_predicate.cpp 1 2 50.00% [222]
🔵 src/exec/query_cache/cache_operator.cpp 32 62 51.61% [242, 243, 246, 247, 248, 249, 254, 255, 256, 257, 258, 259, 260, 262, 263, 264, 267, 268, 269, 270, 273, 280, 281, 286, 287, 288, 289, 291, 293, 298]
🔵 src/exec/iceberg/iceberg_delete_builder.cpp 32 62 51.61% [58, 60, 63, 64, 66, 67, 69, 70, 71, 78, 79, 80, 81, 84, 88, 89, 97, 100, 101, 102, 103, 104, 105, 106, 109, 110, 111, 113, 115, 118]
🔵 src/exec/aggregator.cpp 38 73 52.05% [48, 49, 50, 51, 159, 162, 164, 166, 169, 173, 175, 390, 453, 493, 511, 512, 520, 521, 522, 525, 535, 536, 537, 538, 540, 541, 542, 543, 544, 547, 550, 552, 556, 558, 569]
🔵 src/exec/pipeline/pipeline_driver_executor.cpp 10 19 52.63% [62, 172, 173, 174, 361, 362, 415, 419, 448]
🔵 src/exec/pipeline/pipeline_driver_queue.cpp 8 15 53.33% [254, 258, 259, 260, 261, 265, 268]
🔵 src/storage/tablet_manager.cpp 30 56 53.57% [441, 442, 443, 445, 446, 447, 682, 694, 1045, 1050, 1061, 1062, 1064, 1065, 1071, 1072, 1081, 1111, 1112, 1124, 1125, 1126, 1130, 1132, 1135, 1139]
🔵 src/util/tdigest.cpp 8 15 53.33% [239, 243, 274, 287, 319, 616, 621]
🔵 src/storage/rowset/rowset.cpp 14 26 53.85% [178, 179, 180, 181, 182, 183, 184, 185, 186, 264, 404, 486]
🔵 src/connector/hive_connector.cpp 19 35 54.29% [296, 310, 311, 312, 313, 314, 343, 344, 345, 346, 347, 513, 514, 607, 608, 609]
🔵 src/agent/agent_server.cpp 16 29 55.17% [142, 499, 500, 501, 502, 617, 618, 621, 622, 625, 626, 629, 630]
🔵 src/exec/pipeline/scan/scan_operator.cpp 5 9 55.56% [452, 454, 455, 456]
🔵 src/storage/rowset/horizontal_update_rowset_writer.cpp 4 7 57.14% [51, 68, 105]
🔵 src/serde/column_array_serde.cpp 3 5 60.00% [293, 316]
🔵 src/exec/pipeline/pipeline_driver.cpp 9 15 60.00% [88, 89, 104, 105, 106, 569]
🔵 src/storage/tablet_updates.cpp 47 76 61.84% [380, 415, 416, 588, 681, 1569, 1572, 2164, 2168, 2169, 2480, 2481, 2482, 2483, 2485, 2487, 2490, 2491, 2492, 2682, 2710, 2820, 2918, 3081, 3082, 3083, 3155, 3696, 3760]
🔵 src/exec/workgroup/work_group.cpp 11 18 61.11% [117, 122, 123, 124, 198, 199, 210]
🔵 src/storage/storage_engine.cpp 7 11 63.64% [274, 352, 1005, 1399]
🔵 src/exprs/lambda_function.cpp 25 39 64.10% [39, 40, 44, 48, 49, 53, 54, 57, 58, 75, 76, 77, 98, 99]
🔵 src/storage/lake/compaction_scheduler.cpp 9 14 64.29% [164, 165, 220, 221, 222]
🔵 src/fs/fs_broker.cpp 2 3 66.67% [101]
🔵 src/exec/join_hash_map.cpp 6 9 66.67% [667, 672, 673]
🔵 src/storage/column_aggregate_func.cpp 17 25 68.00% [252, 253, 288, 447, 448, 449, 450, 458]
🔵 src/io/cache_input_stream.cpp 24 34 70.59% [90, 127, 154, 184, 248, 252, 253, 254, 255, 256]
🔵 src/column/nullable_column.cpp 7 10 70.00% [164, 165, 166]
🔵 src/storage/tablet_meta.cpp 16 22 72.73% [231, 232, 233, 234, 235, 236]
🔵 src/exec/pipeline/operator.cpp 8 11 72.73% [300, 305, 311]
🔵 src/simd/simd.h 19 26 73.08% [37, 41, 65, 66, 114, 142, 143]
🔵 src/storage/txn_manager.cpp 19 26 73.08% [275, 278, 288, 289, 290, 309, 352]
🔵 src/storage/rowset/segment_iterator.cpp 112 150 74.67% [374, 377, 385, 386, 514, 536, 537, 612, 615, 619, 633, 652, 653, 654, 655, 657, 658, 659, 661, 662, 663, 665, 666, 670, 673, 674, 675, 677, 678, 679, 680, 683, 778, 815, 1320, 1634, 1635, 1636]
🔵 src/storage/memtable.cpp 3 4 75.00% [329]
🔵 src/storage/lake/update_manager.cpp 12 16 75.00% [305, 624, 625, 626]
🔵 src/storage/aggregate_type.cpp 10 13 76.92% [35, 36, 63]
🔵 src/exprs/function_call_expr.cpp 19 25 76.00% [47, 49, 87, 88, 89, 92]
🔵 src/exprs/array_map_expr.cpp 48 63 76.19% [69, 70, 82, 83, 111, 112, 120, 121, 122, 123, 124, 125, 126, 127, 129]
🔵 src/storage/lake/tablet.cpp 10 13 76.92% [51, 52, 53]
🔵 src/exec/hdfs_scanner_orc.cpp 10 13 76.92% [544, 546, 547]
🔵 src/util/raw_container.h 7 9 77.78% [164, 166]
🔵 src/storage/persistent_index.cpp 14 18 77.78% [1225, 1226, 1385, 2450]
🔵 src/column/binary_column.cpp 21 26 80.77% [755, 763, 764, 768, 770]
🔵 src/types/logical_type.h 4 5 80.00% [176]
🔵 src/fs/fs_posix.cpp 10 12 83.33% [543, 552]
🔵 src/storage/rowset/scalar_column_iterator.cpp 20 24 83.33% [411, 412, 413, 453]
🔵 src/exec/tablet_info.cpp 10 12 83.33% [294, 319]
🔵 src/storage/rowset_update_state.cpp 10 12 83.33% [80, 385]
🔵 src/exec/parquet_reader.cpp 5 6 83.33% [439]
🔵 src/exprs/like_predicate.cpp 49 57 85.96% [459, 481, 482, 483, 529, 530, 531, 560]
🔵 src/storage/tablet_schema.cpp 12 14 85.71% [171, 258]
🔵 src/runtime/descriptors.cpp 12 14 85.71% [266, 375]
🔵 src/storage/protobuf_file.cpp 7 8 87.50% [77]
🔵 src/storage/lake/compaction_policy.cpp 24 27 88.89% [98, 256, 257]
🔵 src/formats/parquet/column_reader.cpp 24 27 88.89% [111, 145, 162]
🔵 src/exec/workgroup/scan_task_queue.cpp 16 18 88.89% [174, 175]
🔵 src/exprs/array_functions.cpp 34 38 89.47% [614, 712, 714, 716]
🔵 src/storage/lake/tablet_manager.cpp 58 64 90.62% [279, 315, 866, 867, 868, 869]
🔵 src/fs/fs.cpp 10 11 90.91% [113]
🔵 src/storage/lake/tablet_reader.cpp 12 13 92.31% [328]
🔵 src/exprs/subfield_expr.cpp 12 13 92.31% [46]
🔵 src/runtime/exec_env.cpp 25 27 92.59% [450, 451]
🔵 src/exec/spill/log_block_manager.cpp 15 16 93.75% [262]
🔵 src/storage/lake/rowset_update_state.cpp 17 18 94.44% [335]
🔵 src/common/configbase.cpp 18 19 94.74% [255]
🔵 src/storage/delta_column_group.cpp 18 19 94.74% [50]
🔵 src/util/threadpool.cpp 35 37 94.59% [263, 530]
🔵 src/storage/rowset_column_update_state.cpp 19 20 95.00% [309]
🔵 src/storage/lake/meta_file.cpp 20 21 95.24% [278]
🔵 src/formats/parquet/meta_helper.cpp 45 47 95.74% [109, 134]
🔵 src/exec/workgroup/scan_task_queue.h 2 2 100.00% []
🔵 src/exprs/split.cpp 1 1 100.00% []
🔵 src/formats/orc/orc_chunk_reader.cpp 2 2 100.00% []
🔵 src/storage/lake/compaction_scheduler.h 2 2 100.00% []
🔵 src/geo/wkt_parse.cpp 1 1 100.00% []
🔵 src/storage/lake/vertical_compaction_task.cpp 2 2 100.00% []
🔵 src/storage/rowset/indexed_column_reader.cpp 1 1 100.00% []
🔵 src/exprs/string_functions.cpp 3 3 100.00% []
🔵 src/exprs/json_functions.cpp 4 4 100.00% []
🔵 src/exec/sorting/compare_column.cpp 1 1 100.00% []
🔵 src/storage/row_source_mask.cpp 2 2 100.00% []
🔵 src/storage/lake/general_tablet_writer.cpp 8 8 100.00% []
🔵 src/exprs/agg/factory/aggregate_factory.hpp 4 4 100.00% []
🔵 src/exec/sorting/sorting.h 1 1 100.00% []
🔵 src/exec/hdfs_scanner.h 1 1 100.00% []
🔵 src/storage/rowset/binary_dict_page.cpp 2 2 100.00% []
🔵 src/storage/lake/rowset.cpp 8 8 100.00% []
🔵 src/storage/rowset/struct_column_writer.cpp 2 2 100.00% []
🔵 src/runtime/stream_load/stream_load_executor.cpp 5 5 100.00% []
🔵 src/exprs/compound_predicate.cpp 1 1 100.00% []
🔵 src/exec/chunks_sorter.cpp 1 1 100.00% []
🔵 src/exec/pipeline/query_context.cpp 21 21 100.00% []
🔵 src/exprs/map_functions.cpp 1 1 100.00% []
🔵 src/exprs/agg/percentile_cont.h 1 1 100.00% []
🔵 src/storage/rowset/column_reader.cpp 4 4 100.00% []
🔵 src/exprs/locate.cpp 1 1 100.00% []
🔵 src/storage/rowset/parsed_page.cpp 17 17 100.00% []
🔵 src/column/const_column.cpp 1 1 100.00% []
🔵 src/exprs/agg/factory/aggregate_factory.cpp 1 1 100.00% []
🔵 src/exprs/array_element_expr.cpp 1 1 100.00% []
🔵 src/formats/parquet/schema.cpp 31 31 100.00% []
🔵 src/storage/rowset/rowset.h 3 3 100.00% []
🔵 src/storage/size_tiered_compaction_policy.cpp 2 2 100.00% []
🔵 src/exec/hdfs_scanner.cpp 17 17 100.00% []
🔵 src/storage/lake/horizontal_compaction_task.cpp 3 3 100.00% []
🔵 src/runtime/lake_tablets_channel.cpp 8 8 100.00% []
🔵 src/storage/horizontal_compaction_task.cpp 1 1 100.00% []
🔵 src/exec/pipeline/pipeline_driver_poller.cpp 10 10 100.00% []
🔵 src/column/nullable_column.h 4 4 100.00% []
🔵 src/formats/parquet/file_reader.cpp 8 8 100.00% []
🔵 src/column/column_viewer.cpp 2 2 100.00% []
🔵 src/util/bfd_parser.cpp 1 1 100.00% []
🔵 src/exec/arrow_to_starrocks_converter.cpp 6 6 100.00% []
🔵 src/column/column_hash.h 6 6 100.00% []
🔵 src/exec/json_scanner.cpp 2 2 100.00% []
🔵 src/storage/lake/delta_writer.cpp 5 5 100.00% []
🔵 src/types/logical_type_infra.h 2 2 100.00% []
🔵 src/http/http_client.cpp 3 3 100.00% []
🔵 src/column/column.cpp 2 2 100.00% []
🔵 src/runtime/runtime_state.cpp 3 3 100.00% []
🔵 src/storage/rowset/segment_rewriter.cpp 27 27 100.00% []
🔵 src/exec/stream/aggregate/agg_group_state.cpp 2 2 100.00% []
🔵 src/column/column_helper.h 12 12 100.00% []
🔵 src/storage/tablet.h 3 3 100.00% []
🔵 src/exec/stream/state/mem_state_table.cpp 1 1 100.00% []
🔵 src/formats/parquet/encoding_dict.h 2 2 100.00% []
🔵 src/exprs/agg/factory/aggregate_resolver_minmaxany.cpp 1 1 100.00% []
🔵 src/storage/lake/tablet.h 1 1 100.00% []
🔵 src/column/schema.cpp 3 3 100.00% []
🔵 src/exec/stream/aggregate/agg_state_data.cpp 1 1 100.00% []
🔵 src/storage/compaction.cpp 1 1 100.00% []
🔵 src/storage/chunk_aggregator.cpp 2 2 100.00% []
🔵 src/types/timestamp_value.cpp 8 8 100.00% []
🔵 src/exprs/agg/distinct.h 8 8 100.00% []
🔵 src/runtime/types.cpp 7 7 100.00% []
🔵 src/storage/rowset/column_iterator.h 2 2 100.00% []
🔵 src/storage/lake/filenames.h 2 2 100.00% []
🔵 src/exec/pipeline/pipeline_driver_poller.h 4 4 100.00% []
🔵 src/storage/lake/txn_log_applier.cpp 3 3 100.00% []
🔵 src/exec/pipeline/pipeline.cpp 1 1 100.00% []
🔵 src/types/bitmap_value.cpp 1 1 100.00% []
🔵 src/formats/parquet/meta_helper.h 2 2 100.00% []
🔵 src/storage/lake/pk_tablet_writer.cpp 3 3 100.00% []
🔵 src/util/starrocks_metrics.h 1 1 100.00% []
🔵 src/util/starrocks_metrics.cpp 6 6 100.00% []
🔵 src/storage/default_compaction_policy.cpp 1 1 100.00% []
🔵 src/util/runtime_profile.h 2 2 100.00% []
🔵 src/exprs/agg/array_agg.h 7 7 100.00% []
🔵 src/storage/update_manager.cpp 7 7 100.00% []
🔵 src/geo/wkt_yacc.y 1 1 100.00% []
🔵 src/exprs/bitmap_functions.cpp 1 1 100.00% []
🔵 src/storage/compaction_task.cpp 8 8 100.00% []
🔵 src/util/system_metrics.cpp 1 1 100.00% []
🔵 src/exec/parquet_scanner.cpp 20 20 100.00% []

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
documentation Improvements or additions to documentation
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[Feature]Trino dialect supports insert syntax