database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity
Files
5fd9f58bd3eca510b825d5dfc92927ffa3f31dc0
doris/be/src/pipeline/exec
History
Pxl 5fd9f58bd3 [Chore](pipeline-engine) adjus queryt canceled log on pipeline engine (#20702) 
adjus queryt canceled log on pipeline engine
2023-06-12 18:23:19 +08:00
..
aggregation_sink_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
aggregation_sink_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
aggregation_source_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
aggregation_source_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
analytic_sink_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
analytic_sink_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
analytic_source_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
analytic_source_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
assert_num_rows_operator.h
[Chore](build) enable -Wpedantic and update lowest gcc version to 11.1 (#16290)
2023-02-03 11:28:48 +08:00
const_value_operator.h
[Chore](build) enable -Wpedantic and update lowest gcc version to 11.1 (#16290)
2023-02-03 11:28:48 +08:00
data_queue.cpp
[Bug](pipeline) set SourceState to MORE_DATA when UnionSourceOperator have const_expr/data_queue->remaining_has_data (#20557)
2023-06-08 14:47:35 +08:00
data_queue.h
[Bug](pipeline) set SourceState to MORE_DATA when UnionSourceOperator have const_expr/data_queue->remaining_has_data (#20557)
2023-06-08 14:47:35 +08:00
datagen_operator.cpp
[Profile](exec) Remove unless profile in pipeline exec engine (#20337)
2023-06-02 11:39:11 +08:00
datagen_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
empty_set_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
empty_set_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
empty_source_operator.cpp
[Bug](memleak) Fix emptyoperator may cause node not close (#20525)
2023-06-07 01:27:13 +08:00
empty_source_operator.h
[Bug](memleak) Fix emptyoperator may cause node not close (#20525)
2023-06-07 01:27:13 +08:00
exchange_sink_buffer.cpp
[improvement](profile)add sum/avg rpc time (#20511)
2023-06-12 11:34:49 +08:00
exchange_sink_buffer.h
[improvement](profile)add sum/avg rpc time (#20511)
2023-06-12 11:34:49 +08:00
exchange_sink_operator.cpp
[improvement](profile)add sum/avg rpc time (#20511)
2023-06-12 11:34:49 +08:00
exchange_sink_operator.h
[improvement](profile)add sum/avg rpc time (#20511)
2023-06-12 11:34:49 +08:00
exchange_source_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
exchange_source_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
hashjoin_build_sink.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
hashjoin_build_sink.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
hashjoin_probe_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
hashjoin_probe_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
multi_cast_data_stream_sink.h
[pipeline](CTE) Support multi stream data sink in pipeline (#19519)
2023-05-18 10:34:37 +08:00
multi_cast_data_stream_source.cpp
[CTE](eof) Support cte reuse reduce counter by eof status and pipeline task mem can release (#20056)
2023-05-26 22:03:29 +08:00
multi_cast_data_stream_source.h
[CTE](eof) Support cte reuse reduce counter by eof status and pipeline task mem can release (#20056)
2023-05-26 22:03:29 +08:00
multi_cast_data_streamer.cpp
[CTE](eof) Support cte reuse reduce counter by eof status and pipeline task mem can release (#20056)
2023-05-26 22:03:29 +08:00
multi_cast_data_streamer.h
[CTE](eof) Support cte reuse reduce counter by eof status and pipeline task mem can release (#20056)
2023-05-26 22:03:29 +08:00
mysql_scan_operator.cpp
[Profile](exec) Remove unless profile in pipeline exec engine (#20337)
2023-06-02 11:39:11 +08:00
mysql_scan_operator.h
[Chore](build) enable -Wpedantic and update lowest gcc version to 11.1 (#16290)
2023-02-03 11:28:48 +08:00
nested_loop_join_build_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
nested_loop_join_build_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
nested_loop_join_probe_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
nested_loop_join_probe_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
olap_table_sink_operator.h
[Chore](build) enable -Wpedantic and update lowest gcc version to 11.1 (#16290)
2023-02-03 11:28:48 +08:00
operator.cpp
[Chore](pipeline-engine) adjus queryt canceled log on pipeline engine (#20702)
2023-06-12 18:23:19 +08:00
operator.h
[Opt](join) short circuit probe for join node (#20585)
2023-06-12 16:01:09 +08:00
partition_sort_sink_operator.h
[vectorized](feature) support partition sort node (#19708)
2023-05-25 11:22:02 +08:00
partition_sort_source_operator.h
[vectorized](feature) support partition sort node (#19708)
2023-05-25 11:22:02 +08:00
repeat_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
repeat_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
result_file_sink_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
result_file_sink_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
result_sink_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
result_sink_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
scan_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
scan_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
schema_scan_operator.cpp
[Profile](exec) Remove unless profile in pipeline exec engine (#20337)
2023-06-02 11:39:11 +08:00
schema_scan_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
select_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
select_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
set_probe_sink_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
set_probe_sink_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
set_sink_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
set_sink_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
set_source_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
set_source_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
sort_sink_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
sort_sink_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
sort_source_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
sort_source_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
streaming_aggregation_sink_operator.cpp
[Profile](exec) Remove unless profile in pipeline exec engine (#20337)
2023-06-02 11:39:11 +08:00
streaming_aggregation_sink_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
streaming_aggregation_source_operator.cpp
[Profile](exec) Remove unless profile in pipeline exec engine (#20337)
2023-06-02 11:39:11 +08:00
streaming_aggregation_source_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
table_function_operator.cpp
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
table_function_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
table_sink_operator.h
[Chore](build) enable -Wpedantic and update lowest gcc version to 11.1 (#16290)
2023-02-03 11:28:48 +08:00
union_sink_operator.cpp
[Profile](exec) Remove unless profile in pipeline exec engine (#20337)
2023-06-02 11:39:11 +08:00
union_sink_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00
union_source_operator.cpp
[Chore](pipeline-engine) adjus queryt canceled log on pipeline engine (#20702)
2023-06-12 18:23:19 +08:00
union_source_operator.h
[chore](build) Use include-what-you-use to optimize includes (PART II) (#18761)
2023-04-19 23:11:48 +08:00