ClickHouse/dbms/src/Processors
2019-12-03 03:51:10 +03:00
..
Executors Add thread name for pipeline threads. 2019-11-09 22:46:46 +03:00
Formats Update ValuesBlockInputFormat.cpp 2019-12-03 03:51:10 +03:00
Sources Skip empty totals in SourceFromInputStream. 2019-11-05 15:50:47 +03:00
tests Wait for jobs to finish on exception (fixes rare segfaults) (#7350) 2019-10-17 17:41:27 +03:00
Transforms Replace pointer with reference in SettingsCollection<T>::MemberInfos::findStrict(). 2019-11-17 03:51:51 +03:00
Chunk.cpp Fix build. 2019-10-22 02:49:44 +03:00
Chunk.h Review fixes. 2019-10-21 19:26:29 +03:00
CMakeLists.txt
ConcatProcessor.cpp
ConcatProcessor.h
ForkProcessor.cpp
ForkProcessor.h
IAccumulatingTransform.cpp
IAccumulatingTransform.h Added AggregatingTransform. 2019-04-03 13:13:25 +03:00
IInflatingTransform.cpp
IInflatingTransform.h
IProcessor.cpp
IProcessor.h Added Pipe class. Updated MergeTreeDataSelectExecutor. 2019-10-21 18:16:08 +03:00
ISimpleTransform.cpp adding -Wshadow for GCC 2019-08-09 23:58:16 +03:00
ISimpleTransform.h adding -Wshadow for GCC 2019-08-09 23:58:16 +03:00
ISink.cpp
ISink.h
ISource.cpp
ISource.h Added Pipe class. Updated MergeTreeDataSelectExecutor. 2019-10-21 18:16:08 +03:00
LimitTransform.cpp limit with ties for processors 2019-08-27 20:48:42 +03:00
LimitTransform.h limit with ties for processors 2019-08-27 20:48:42 +03:00
NullSink.h
Pipe.cpp Fix limits for pipe. 2019-11-06 14:36:33 +03:00
Pipe.h Less wrappers for procesors pipeline. 2019-11-05 20:33:03 +03:00
Port.cpp
Port.h Get rid of InputStream layer for Kafka, use InputStream directly. Reopening port during reset. 2019-11-28 17:43:06 +01:00
printPipeline.h
QueryPipeline.cpp move table locks to main pipeline 2019-11-21 18:37:59 +03:00
QueryPipeline.h hold shared pointers to table function Storage and Context from InterpreterSelectQuery 2019-11-15 21:42:32 +03:00
QueueBuffer.h
ResizeProcessor.cpp Update ResizePipeline 2019-07-09 20:47:13 +03:00
ResizeProcessor.h
SharedChunk.h limit with ties for processors 2019-08-27 20:48:42 +03:00