Nikolai Kochetov
8bfd909f5b
Update JSONEachRowRowOutputFormat.
2019-07-31 13:06:46 +03:00
Nikolai Kochetov
5bdb6aa9f3
Update TSKVRowInputFormat.
2019-07-31 12:43:20 +03:00
Nikolai Kochetov
b274545bb7
Update CSVRowInputFormat.
2019-07-30 21:48:40 +03:00
Nikolai Kochetov
e8b643e032
Update CSVRowInputFormat.
2019-07-30 21:22:01 +03:00
Nikolai Kochetov
ee3a93bab5
Update CSVRowInputFormat.
2019-07-30 21:21:12 +03:00
Nikolai Kochetov
d4da486b51
Update CSVRowInputFormat.
2019-07-30 17:55:59 +03:00
Nikolai Kochetov
95dd6222fe
Use IInputFormat and IOutputFormat by default.
2019-07-25 15:17:57 +03:00
Nikolai Kochetov
78f056d83f
Use IInputFormat and IOutputFormat by default.
2019-07-25 12:35:16 +03:00
Nikolai Kochetov
36a0275ff1
Use IInputFormat and IOutputFormat by default.
2019-07-25 12:31:38 +03:00
Nikolai Kochetov
69f860a5ef
Use IInputFormat and IOutputFormat by default.
2019-07-25 12:28:33 +03:00
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