Nikolai Kochetov
a22540d010
Use IInputFormat and IOutputFormat by default.
2019-07-25 12:20:00 +03:00
Nikolai Kochetov
4cc3bf7724
Use IInputFormat and IOutputFormat by default.
2019-07-25 12:15:33 +03:00
Nikolai Kochetov
58d579e7e2
Use IInputFormat and IOutputFormat by default.
2019-07-24 21:00:09 +03:00
Alexander Kuzmenkov
9df09f3506
Do not access shared arenas in aggregate function columns.
...
These arenas may be updated concurrently, so it is unsafe to
access them, as illustrated by issue #4402 . Store them separately
and use a different arena for the updates. Change some callers
to accomodate for this.
2019-07-18 14:21:37 +03:00
Nikolai Kochetov
bfa114126a
More comments for PipelineExecutor.
2019-07-11 09:50:44 +03:00
Nikolai Kochetov
d104f2d8ff
Update PipelineExecutor
2019-07-10 14:59:30 +03:00
Nikolai Kochetov
282feb1fdb
Update PipelineExecutor
2019-07-10 09:52:44 +03:00
Nikolai Kochetov
6974cc3c9f
Update ResizePipeline
2019-07-09 20:47:13 +03:00
Nikolai Kochetov
911e4014ff
Increase queue size in LazyOutputFormat in order to prevent potential lock.
2019-07-09 15:26:22 +03:00
Nikolai Kochetov
27acbb0412
Fix tests.
2019-07-08 21:08:44 +03:00
Nikolai Kochetov
de2221222e
Don't skip empty chunks in Filter Transform.
2019-07-08 18:52:18 +03:00
Nikolai Kochetov
2128fb890b
Don't skip empty chunks in Filter Transform.
2019-07-08 18:23:45 +03:00
Nikolai Kochetov
e0362c5216
Fix build.
2019-07-08 16:15:45 +03:00
Nikolai Kochetov
472f32f718
Remove ThreadGroupThreadPoolCallbacks
2019-07-08 15:49:52 +03:00
Nikolai Kochetov
e5103d741c
Fix lock in case of query was cancelled.
2019-07-08 15:48:16 +03:00
Nikolai Kochetov
fc3b465d60
Fix race in doExpandPipeline.
2019-07-08 15:49:46 +03:00
Nikolai Kochetov
a27fbe6ea7
Removed lockfree stack.
2019-07-08 15:49:33 +03:00
Nikolai Kochetov
45b7d479aa
Fix arguments in prepareProcessor call.
2019-07-08 15:49:23 +03:00
Nikolai Kochetov
02bded6f21
Added MySQLOutputFormat.
2019-07-08 15:49:15 +03:00
Nikolai Kochetov
acf382f9e5
Use boost::lockfree::stack instead of boost::lockfree::queue
2019-07-08 15:48:51 +03:00
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
1f6bbeee7d
Update Port.h
2019-06-25 19:41:06 +03:00
Nikolai Kochetov
94e087102d
Use std::pair in port.
2019-06-25 19:41:06 +03:00
Nikolai Kochetov
6c2dd9b87d
Remove copy constructor from Chunk.
2019-06-25 19:41:59 +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
8299680efe
Update Port.h
2019-06-25 19:41:06 +03:00
Nikolai Kochetov
76934cf801
Don't call cancell for RemoteBlockInputStream in SourceFromInputStream.
2019-06-25 19:41:06 +03:00
Nikolai Kochetov
f5e20027a7
Better exception safety for SourceFromInputStream.
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
821d520a52
Fix limit by offset.
2019-06-25 19:41:06 +03:00
Nikolai Kochetov
cc09bb5557
Fix distinct.
2019-06-25 19:41:06 +03:00
Nikolai Kochetov
96174e90b0
Fix build.
2019-06-25 19:41:00 +03:00
Nikolai Kochetov
4ef3ff7270
Better exception safety for ISource and MergingAggregatedTransform.
2019-05-14 12:50:04 +03:00
Nikolai Kochetov
6a781cf2c8
Free chunks when merge sort is finished at MergeSorter.
2019-05-13 17:57:49 +03:00
Nikolai Kochetov
ba6768557e
Fix rows_before_limit_at_least.
2019-05-13 16:04:52 +03:00
Nikolai Kochetov
fe9a45fee1
Fix rows_before_limit_at_least.
2019-05-13 15:08:02 +03:00
Nikolai Kochetov
18a7b0d7a2
Fix data race in PipelineExecutor.
2019-05-13 13:03:47 +03:00
Nikolai Kochetov
b8adb0937f
Do not create processors for totals stream.
2019-04-30 20:37:30 +03:00
Nikolai Kochetov
ad8af5b5ba
Do not create processors for totals stream.
2019-04-30 20:12:43 +03:00