Commit Graph

32 Commits

Author SHA1 Message Date
Nikolai Kochetov
f808d71aba Fix build. 2019-07-08 15:48:16 +03:00
Nikolai Kochetov
50aac7e982 Atomic Ports. [2] 2019-06-25 19:42:57 +03:00
Nikolai Kochetov
67b7080707 Atomic Ports. 2019-06-25 19:42:26 +03:00
Nikolai Kochetov
ab781f0988 Add task_queue to PipelineExecutor. 2019-06-25 19:42:05 +03:00
Nikolai Kochetov
d0cd3cc640 Update PipelineExecutor 2019-06-25 19:41:06 +03:00
Nikolai Kochetov
11e0752f6d Update PipelineExecutor. 2019-06-25 19:41:55 +03:00
Nikolai Kochetov
c6bbf6d91d Process pipeline in each thread in PipelineExecutor.
Exception safety in PipelineExecutor.
2019-06-25 19:41:38 +03:00
Nikolai Kochetov
d8f0c6c15a Added stream number to pipeline execution state. 2019-06-25 19:41:28 +03:00
Nikolai Kochetov
3bee30a215 Update PipelineExecutor. 2019-06-25 19:41:11 +03:00
Nikolai Kochetov
fc5f28faeb Remove ExceptionHandler from PipelineExecutor. 2019-06-25 19:41:06 +03:00
Nikolai Kochetov
1ae23a6d9d Don't throw exception if query was cannelled. 2019-06-25 19:41:06 +03:00
Nikolai Kochetov
18a7b0d7a2 Fix data race in PipelineExecutor. 2019-05-13 13:03:47 +03:00
Nikolai Kochetov
72c0530845 Do not create processors for totals stream. 2019-04-30 20:01:12 +03:00
Nikolai Kochetov
249a88784b Remove thread group from PipelineExecutor task. 2019-04-30 15:51:25 +03:00
Nikolai Kochetov
ced8e607f1 Wait for tasks from thread pool in case of exception in PipelineExecutor. 2019-04-30 15:28:11 +03:00
Nikolai Kochetov
aacc0572e5 Attach to current thread in threadpool. 2019-04-29 16:57:29 +03:00
Nikolai Kochetov
caf9ed639b Attach tasks from PipelineExecutor to thread group. 2019-04-29 14:04:03 +03:00
Nikolai Kochetov
13800ac650 Don't add info about processors to TOO_MANY_ROWS_OR_BYTES exception. 2019-04-26 20:33:46 +03:00
Nikolai Kochetov
e2a41a031a Don't add info about processors to TOO_MANY_ROWS_OR_BYTES exception. 2019-04-26 20:21:14 +03:00
Nikolai Kochetov
3f778e7aaf Don't require AggregatedChunkInfo in TotalsHavingTransform if no overflow_row. 2019-04-16 17:37:19 +03:00
Nikolai Kochetov
43fdf4575c Better pipeline expanding. MergeSortingTransform refactoring. 2019-04-16 14:40:15 +03:00
Nikolai Kochetov
a6d0b2102e Don't shwallow exceptions at executeJob. 2019-04-12 14:27:25 +03:00
Nikolai Kochetov
750b5a1b07 Added more information to exception from processor. 2019-04-12 14:18:18 +03:00
Nikolai Kochetov
c92fb23317 Add pipeline to exception during query execution. 2019-04-12 12:57:13 +03:00
Nikolai Kochetov
fa5bc611ae Better exceptions safety in PipelineExecutor. 2019-04-08 14:06:11 +03:00
Nikolai Kochetov
7626b1b267 Multiple fixes. 2019-04-05 13:52:07 +03:00
Nikolai Kochetov
18133a4948 Added processors_test_aggregation. 2019-04-03 13:13:25 +03:00
Nikolai Kochetov
c388e57a40 Fix MergingSortedTransform. Update PipelineExecutor. 2019-04-03 13:13:25 +03:00
Nikolai Kochetov
19fa17fd84 Added ExpandPipeline to PipelineExecutor.
Added expanding pipeline test.
2019-04-03 13:13:37 +03:00
Nikolai Kochetov
1e3ca041a2 Added ExpandPipeline processor status. Changed types of InputPorts and OutputPorts from vector to list. 2019-04-03 13:13:25 +03:00
Nikolai Kochetov
6763b59ba9 Updated PipelineExecutor. 2019-02-15 19:18:25 +03:00
Nikolai Kochetov
f55f70d67b Added PipelineExecutor. 2019-02-15 19:18:12 +03:00