Nikolai Kochetov
|
3ff5495fba
|
Fix raise in PipelineExecutor::doExpandPipeline
|
2019-07-08 15:48:41 +03:00 |
|
Nikolai Kochetov
|
3df6d12216
|
More comments for PipelineExecutor.
|
2019-07-08 15:48:16 +03:00 |
|
Nikolai Kochetov
|
e8b4362ed2
|
Use ThreadPool in PipelineExecutor.
|
2019-07-08 15:48:32 +03:00 |
|
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 |
|