File tree
1,586 files changed
+34669
-110327
lines changed- .config
- .github
- actions
- build_linux
- build_macos
- check
- setup_license
- scripts
- workflows
- docker
- it-hive
- it-iceberg-rest
- src
- binaries
- query
- tool
- common
- arrow
- src
- arrow
- array
- binary
- binview
- boolean
- dictionary
- equal
- fixed_size_binary
- fixed_size_list
- growable
- list
- map
- primitive
- struct_
- union
- utf8
- compute
- aggregate
- cast
- merge_sort
- sort
- primitive
- row
- take
- datatypes
- ffi
- io
- flight
- ipc
- append
- read
- array
- write
- parquet
- read
- deserialize
- binary
- binview
- boolean
- dictionary
- fixed_size_binary
- null
- primitive
- indexes
- schema
- statistics
- write
- binary
- binview
- boolean
- nested
- primitive
- utf8
- scalar
- util
- native
- read
- array
- write
- tests/it
- arrow
- array
- binary
- binview
- boolean
- dictionary
- equal
- fixed_size_binary
- fixed_size_list
- growable
- list
- map
- primitive
- struct_
- utf8
- buffer
- compute
- aggregate
- sort
- row
- ffi
- scalar
- native
- auth
- base
- src
- base
- mem_allocator
- tests/it
- building
- src
- cache
- column
- src
- binary
- binview
- bitmap
- utils
- chunk_iterator
- buffer
- types
- simd
- tests/it
- binview
- bitmap
- utils
- buffer
- compress
- exception
- src
- elf
- tests/it
- hashtable
- src
- http
- io
- src
- cursor_ext
- tests/it/cursor_ext
- metrics
- src/metrics
- native
- src
- compression
- binary
- boolean
- double
- integer
- read
- array
- util
- write
- tests/it
- native
- parquet2
- src
- bloom_filter
- deserialize
- encoding
- bitpacked
- delta_bitpacked
- delta_byte_array
- delta_length_byte_array
- hybrid_rle
- indexes
- metadata
- page
- read
- column
- indexes
- page
- schema
- io_message
- io_thrift
- types
- statistics
- write
- indexes
- storage
- src
- tests/it
- tracing
- src
- vector
- meta
- api
- src
- kv_pb_api
- app
- src
- background
- principal
- schema
- binaries
- metabench
- metactl
- metaverifier
- meta
- client
- src
- embedded
- src
- tests/it
- kvapi/src/kvapi
- process/src
- proto-conv
- src
- tests/it
- protos
- proto
- raft-store
- src
- leveled_store
- log
- ondisk
- raft_log_v004
- sm_v003
- state_machine
- state
- tests/it
- state_machine
- service
- src
- api
- grpc
- http/v1
- configs
- meta_service
- metrics
- store
- tests/it
- grpc
- meta_node
- tests
- sled-store
- src
- tests/it
- testing
- stoerr
- src
- store
- src
- types
- proto
- src
- cmd
- errors
- proto_ext
- query
- ast
- src
- ast
- format/syntax
- statements
- parser
- tests/it
- testdata
- catalog
- src
- catalog
- plan
- datasource
- datasource_info
- codegen/src/writes
- config
- src
- datavalues
- ee_features
- background_service
- src
- vacuum_handler/src
- ee
- src
- attach_table
- background_service
- license
- storages/fuse/operations
- tests/it
- inverted_index
- storages/fuse/operations
- expression
- benches
- src
- aggregate
- converts
- arrow2
- arrow
- meta
- filter
- select_value
- kernels
- group_by_hash
- row
- types
- utils
- tests/it
- testdata
- formats
- src
- field_decoder
- field_encoder
- output_format
- tests/it
- functions
- src
- aggregates
- adaptors
- scalars
- decimal
- srfs
- tests/it
- aggregates/testdata
- scalars
- testdata
- management
- src
- cluster
- role
- serde
- setting
- udf
- user
- tests/it
- pipeline
- core
- src/processors
- sinks
- transforms/src/processors/transforms
- sort/rows
- script
- src
- service
- src
- catalogs/default
- clusters
- databases/system
- interpreters
- access
- hook
- local
- pipelines
- builders
- processors/transforms
- group_by
- hash_join
- probe_join
- range_join
- window/partition
- schedulers
- fragments
- servers
- admin/v1
- flight/v1
- actions
- exchange
- scatter
- http
- middleware
- v1
- query
- session
- mysql/writers
- sessions
- spillers
- table_functions
- cloud
- infer_schema
- inspect_parquet
- list_stage
- others
- show_grants
- test_kits
- tests/it
- servers
- flight
- http
- sessions
- sql
- exec
- planner/optimizer
- storages
- fuse
- operations
- mutation
- testdata
- settings
- src
- sql
- src
- executor
- physical_plans
- planner
- binder
- bind_mutation
- bind_query
- bind_table_reference
- ddl
- format
- optimizer
- cascades
- tasks
- decorrelate
- hyper_dp
- rule
- rewrite
- plans
- ddl
- semantic
- tests
- storages
- common
- blocks/src
- cache
- src
- read
- index
- benches
- src
- tests/it/filters
- io/src
- pruner/src
- session
- src
- table_meta
- src
- meta
- v2
- v3/frozen
- table
- delta
- fuse
- src
- io
- read
- agg_index
- block
- parquet
- meta
- virtual_column
- write
- operations
- merge_into/mutator
- mutation/processors
- read
- replace_into/mutator
- pruning
- statistics
- table_functions
- hive/hive
- src
- iceberg
- src
- parquet
- src/parquet_rs/parquet_reader
- read_policy
- stage
- src
- append/parquet_file
- read
- row_based/formats/csv
- system
- src
- tests/sqlsmith
- src
- bin
- sql_gen
- tests
- compat
- meta_meta
- metactl
- sqllogictests
- scripts
- src
- client
- mock_source
- suites
- base
- 01_system
- 03_common
- 05_ddl
- 06_show
- 09_fuse_engine
- 11_data_type
- 20+_others
- ee
- 03_ee_vacuum
- 06_ee_stream
- glue
- mode
- cluster
- memo
- standalone
- ee
- explain_native
- push_down_filter
- explain
- push_down_filter
- no_table_meta_cache
- query
- functions
- join
- stage/formats/parquet/options
- temp_table
- tpcds
- tpch_iceberg
- suites
- 0_stateless
- 18_rbac
- 20+_others
- 1_stateful
- 00_stage
- 02_query
- 05_formats/05_05_parquet
- 07_stage_attachment
- 08_select_stage/08_00_parquet
- 09_http_handler
- 5_ee/01_vacuum
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,586 files changed
+34669
-110327
lines changedLines changed: 57 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + |
Lines changed: 5 additions & 29 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
30 | 30 |
| |
31 | 31 |
| |
32 | 32 |
| |
33 |
| - | |
| 33 | + | |
34 | 34 |
| |
35 | 35 |
| |
36 | 36 |
| |
| |||
64 | 64 |
| |
65 | 65 |
| |
66 | 66 |
| |
67 |
| - | |
68 |
| - | |
69 |
| - | |
70 |
| - | |
71 |
| - | |
72 |
| - | |
73 |
| - | |
74 |
| - | |
75 |
| - | |
76 |
| - | |
77 |
| - | |
78 |
| - | |
79 |
| - | |
80 |
| - | |
81 |
| - | |
82 |
| - | |
83 |
| - | |
84 |
| - | |
85 |
| - | |
86 |
| - | |
87 |
| - | |
88 |
| - | |
89 |
| - | |
90 |
| - | |
91 | 67 |
| |
92 |
| - | |
| 68 | + | |
93 | 69 |
| |
94 | 70 |
| |
95 | 71 |
| |
96 | 72 |
| |
97 | 73 |
| |
98 |
| - | |
| 74 | + | |
99 | 75 |
| |
100 | 76 |
| |
101 | 77 |
| |
102 | 78 |
| |
103 |
| - | |
| 79 | + | |
104 | 80 |
| |
105 | 81 |
| |
106 | 82 |
| |
107 | 83 |
| |
108 | 84 |
| |
109 |
| - | |
| 85 | + | |
110 | 86 |
| |
111 | 87 |
| |
112 | 88 |
| |
|
Lines changed: 3 additions & 22 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
32 | 32 |
| |
33 | 33 |
| |
34 | 34 |
| |
35 |
| - | |
36 | 35 |
| |
37 | 36 |
| |
38 | 37 |
| |
| |||
41 | 40 |
| |
42 | 41 |
| |
43 | 42 |
| |
44 |
| - | |
45 |
| - | |
46 |
| - | |
47 |
| - | |
48 |
| - | |
49 |
| - | |
50 |
| - | |
51 |
| - | |
52 |
| - | |
53 |
| - | |
54 |
| - | |
55 |
| - | |
56 |
| - | |
57 |
| - | |
58 |
| - | |
59 |
| - | |
60 |
| - | |
61 |
| - | |
62 |
| - | |
| 43 | + | |
63 | 44 |
| |
64 | 45 |
| |
65 | 46 |
| |
66 | 47 |
| |
67 |
| - | |
| 48 | + | |
68 | 49 |
| |
69 | 50 |
| |
70 |
| - | |
| 51 | + | |
71 | 52 |
| |
72 | 53 |
| |
73 | 54 |
| |
|
Lines changed: 3 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
38 | 38 |
| |
39 | 39 |
| |
40 | 40 |
| |
41 |
| - | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
42 | 44 |
| |
43 | 45 |
| |
44 | 46 |
| |
|
Lines changed: 8 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
5 | 5 |
| |
6 | 6 |
| |
7 | 7 |
| |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
8 | 12 |
| |
9 | 13 |
| |
10 | 14 |
| |
| |||
13 | 17 |
| |
14 | 18 |
| |
15 | 19 |
| |
16 |
| - | |
17 |
| - | |
| 20 | + | |
| 21 | + | |
18 | 22 |
| |
19 | 23 |
| |
20 | 24 |
| |
21 | 25 |
| |
22 | 26 |
| |
23 |
| - | |
24 |
| - | |
| 27 | + | |
| 28 | + | |
25 | 29 |
| |
26 | 30 |
| |
27 | 31 |
| |
|
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
32 | 32 |
| |
33 | 33 |
| |
34 | 34 |
| |
| 35 | + | |
35 | 36 |
| |
36 | 37 |
| |
37 |
| - | |
| 38 | + | |
38 | 39 |
| |
39 | 40 |
| |
40 | 41 |
| |
| |||
52 | 53 |
| |
53 | 54 |
| |
54 | 55 |
| |
55 |
| - | |
56 | 56 |
| |
57 | 57 |
| |
58 | 58 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
22 | 22 |
| |
23 | 23 |
| |
24 | 24 |
| |
25 |
| - | |
| 25 | + | |
26 | 26 |
| |
27 | 27 |
| |
28 | 28 |
| |
|
Lines changed: 4 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
45 | 45 |
| |
46 | 46 |
| |
47 | 47 |
| |
48 |
| - | |
| 48 | + | |
49 | 49 |
| |
50 | 50 |
| |
51 | 51 |
| |
| |||
59 | 59 |
| |
60 | 60 |
| |
61 | 61 |
| |
| 62 | + | |
| 63 | + | |
62 | 64 |
| |
63 | 65 |
| |
64 | 66 |
| |
| |||
69 | 71 |
| |
70 | 72 |
| |
71 | 73 |
| |
72 |
| - | |
| 74 | + | |
73 | 75 |
| |
74 | 76 |
| |
75 | 77 |
| |
|
Lines changed: 4 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
23 | 23 |
| |
24 | 24 |
| |
25 | 25 |
| |
26 |
| - | |
| 26 | + | |
27 | 27 |
| |
28 | 28 |
| |
29 | 29 |
| |
| |||
50 | 50 |
| |
51 | 51 |
| |
52 | 52 |
| |
53 |
| - | |
| 53 | + | |
54 | 54 |
| |
| 55 | + | |
55 | 56 |
| |
56 | 57 |
| |
57 | 58 |
| |
58 | 59 |
| |
59 | 60 |
| |
60 | 61 |
| |
61 | 62 |
| |
62 |
| - | |
| 63 | + | |
63 | 64 |
| |
64 | 65 |
| |
65 | 66 |
| |
|
Lines changed: 3 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 |
| - | |
| 1 | + | |
2 | 2 |
| |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
6 | 6 |
| |
7 |
| - | |
8 | 7 |
| |
9 | 8 |
| |
10 | 9 |
| |
| |||
16 | 15 |
| |
17 | 16 |
| |
18 | 17 |
| |
19 |
| - | |
| 18 | + | |
20 | 19 |
| |
21 | 20 |
| |
22 | 21 |
| |
| |||
45 | 44 |
| |
46 | 45 |
| |
47 | 46 |
| |
| 47 | + | |
48 | 48 |
| |
49 | 49 |
| |
50 | 50 |
| |
|
0 commit comments