ClickHouse/dbms/src/DataStreams
2019-07-01 11:11:53 +03:00
..
tests Style fixed 2019-03-28 12:02:56 +03:00
AddingConstColumnBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
AddingDefaultBlockOutputStream.cpp CLICKHOUSE-4127: Convert destination table's data when reading from 2018-11-27 03:43:58 +03:00
AddingDefaultBlockOutputStream.h Finally fixed 2018-09-20 18:35:52 +03:00
AddingDefaultsBlockInputStream.cpp fixes for review CLICKHOUSE-3578 2018-12-06 20:20:17 +03:00
AddingDefaultsBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
AddingMissedBlockInputStream.cpp resolve class name conflict 2018-12-05 15:27:21 +03:00
AddingMissedBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
AggregatingBlockInputStream.cpp Show error to client if query was killed (#1989) 2018-03-06 00:09:39 +03:00
AggregatingBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
AggregatingSortedBlockInputStream.cpp Allocates arena for SimpleAggregateFunction only if IAggregateFunction requires 2019-05-19 03:33:04 +03:00
AggregatingSortedBlockInputStream.h Allocates arena for SimpleAggregateFunction only if IAggregateFunction requires 2019-05-19 03:33:04 +03:00
AsynchronousBlockInputStream.cpp Fixed thread names 2019-02-11 00:15:14 +03:00
AsynchronousBlockInputStream.h Removed unused code related to MemoryTracker 2019-04-06 01:35:56 +03:00
BlockIO.h Fix order of destruction 2019-05-23 16:54:11 +03:00
BlocksListBlockInputStream.h Fix bug in merging algorithm 2019-03-19 16:10:24 +03:00
BlockStreamProfileInfo.cpp Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
BlockStreamProfileInfo.h Merge ITableDeclaration into IStorage. 2019-05-17 17:34:25 +03:00
CMakeLists.txt
CollapsingFinalBlockInputStream.cpp
CollapsingFinalBlockInputStream.h Resolved some of PVS-Studio warnings 2019-04-22 19:07:09 +03:00
CollapsingSortedBlockInputStream.cpp Better stop condition 2019-03-28 14:12:59 +03:00
CollapsingSortedBlockInputStream.h Fix build 2019-03-28 12:31:57 +03:00
ColumnGathererStream.cpp Fixed error 2019-03-28 19:48:14 +03:00
ColumnGathererStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
ConcatBlockInputStream.h Addition to prev. revision #4297 2019-02-08 18:21:06 +03:00
ConvertColumnLowCardinalityToFullBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
ConvertingBlockInputStream.cpp Revert "Revert "Merge branch 'master' into CLICKHOUSE-3893"" 2018-09-05 12:47:57 +03:00
ConvertingBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
copyData.cpp Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
copyData.h Merge ITableDeclaration into IStorage. 2019-05-17 17:34:25 +03:00
CountingBlockOutputStream.cpp Progress rename for total_rows and write_[rows|bytes] 2019-05-20 18:37:41 +07:00
CountingBlockOutputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
CreatingSetsBlockInputStream.cpp allow acquiring read lock to a table out of order if it was already locked by the same query [#CLICKHOUSE-3789] 2019-02-27 21:34:38 +03:00
CreatingSetsBlockInputStream.h allow acquiring read lock to a table out of order if it was already locked by the same query [#CLICKHOUSE-3789] 2019-02-27 21:34:38 +03:00
CubeBlockInputStream.cpp fix bug 2018-09-21 10:23:31 +03:00
CubeBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
DistinctBlockInputStream.cpp Cleanups #4246 2019-02-10 18:17:45 +03:00
DistinctBlockInputStream.h Cleanups #4246 2019-02-10 18:17:45 +03:00
DistinctSortedBlockInputStream.cpp Cleanups #4246 2019-02-10 18:17:45 +03:00
DistinctSortedBlockInputStream.h Cleanups #4246 2019-02-10 18:17:45 +03:00
ExpressionBlockInputStream.cpp Commit offsets for SELECTing from Kafka table too 2019-06-20 15:34:25 +03:00
ExpressionBlockInputStream.h move caching to ctor 2019-05-16 20:16:25 +03:00
FilterBlockInputStream.cpp Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
FilterBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
FilterColumnsBlockInputStream.cpp
FilterColumnsBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
finalizeBlock.cpp whitespaces 2018-09-07 17:21:11 +03:00
finalizeBlock.h whitespaces 2018-09-07 17:21:11 +03:00
FinishSortingBlockInputStream.cpp Cleanups #4246 2019-02-10 18:17:45 +03:00
FinishSortingBlockInputStream.h Cleanups #4246 2019-02-10 18:17:45 +03:00
GraphiteRollupSortedBlockInputStream.cpp Update GraphiteRollupSortedBlockInputStream.cpp 2019-03-06 03:09:49 +03:00
GraphiteRollupSortedBlockInputStream.h Review adjustment 2019-03-08 08:00:46 +01:00
IBlockInputStream.cpp Progress rename for total_rows and write_[rows|bytes] 2019-05-20 18:37:41 +07:00
IBlockInputStream.h Merge ITableDeclaration into IStorage. 2019-05-17 17:34:25 +03:00
IBlockOutputStream.h Merge ITableDeclaration into IStorage. 2019-05-17 17:34:25 +03:00
IBlockStream_fwd.h Merge ITableDeclaration into IStorage. 2019-05-17 17:34:25 +03:00
InputStreamFromASTInsertQuery.cpp Removed bad and useless code in ColumnsDescription 2019-05-02 00:43:05 +03:00
InputStreamFromASTInsertQuery.h const insert interpreter 2019-03-29 23:47:16 +08:00
InternalTextLogsRowOutputStream.cpp Revert "Revert "Merge branch 'master' into CLICKHOUSE-3893"" 2018-09-05 12:47:57 +03:00
InternalTextLogsRowOutputStream.h Revert "Revert "Merge branch 'master' into CLICKHOUSE-3893"" 2018-09-05 12:47:57 +03:00
LazyBlockInputStream.h Addition to prev. revision #4297 2019-02-08 20:17:16 +03:00
LimitBlockInputStream.cpp Update LimitBlockInputStream.cpp 2019-03-08 18:15:30 +03:00
LimitBlockInputStream.h Fix broken progress in 19.3 (regression in 92769a2460) 2019-03-08 15:36:40 +01:00
LimitByBlockInputStream.cpp added offset for limit by 2019-04-29 16:12:39 +03:00
LimitByBlockInputStream.h added offset for limit by 2019-04-29 16:12:39 +03:00
MarkInCompressedFile.h Use mimalloc instead of lfallocator 2019-06-27 18:13:19 +03:00
materializeBlock.cpp Simplified logic with "IColumn::convertToFullColumnIfConst" (suggested by Amos Bird) [#CLICKHOUSE-2] 2018-12-21 19:00:07 +03:00
materializeBlock.h
MaterializingBlockInputStream.cpp
MaterializingBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
MaterializingBlockOutputStream.h
MergeSortingBlockInputStream.cpp Cleanups #4246 2019-02-10 18:17:45 +03:00
MergeSortingBlockInputStream.h Cleanups #4246 2019-02-10 18:17:45 +03:00
MergingAggregatedBlockInputStream.cpp
MergingAggregatedBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
MergingAggregatedMemoryEfficientBlockInputStream.cpp Removed unused code related to MemoryTracker 2019-04-06 01:35:56 +03:00
MergingAggregatedMemoryEfficientBlockInputStream.h Removed unused code related to MemoryTracker 2019-04-06 01:35:56 +03:00
MergingSortedBlockInputStream.cpp Remove useless code 2019-04-01 14:29:31 +03:00
MergingSortedBlockInputStream.h Resolved some of PVS-Studio warnings 2019-04-22 19:07:09 +03:00
narrowBlockInputStreams.cpp
narrowBlockInputStreams.h
NativeBlockInputStream.cpp Fix cyclic lib depend ppart 2: clean 2018-12-28 21:15:26 +03:00
NativeBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
NativeBlockOutputStream.cpp Addition to prev. revision #4246 2019-02-10 19:22:38 +03:00
NativeBlockOutputStream.h Addition to prev. revision #4246 2019-02-10 19:22:38 +03:00
NullAndDoCopyBlockInputStream.h Addition to prev. revision #4297 2019-02-07 00:44:17 +03:00
NullBlockInputStream.h Namespace comments are unneeded according to the code style. 2019-06-13 13:37:13 +03:00
NullBlockOutputStream.h
OneBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
OwningBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
ParallelAggregatingBlockInputStream.cpp
ParallelAggregatingBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
ParallelInputsProcessor.h Merge pull request #4930 from yandex/tsan-miscellaneous 2019-07-01 11:11:53 +03:00
PartialSortingBlockInputStream.cpp
PartialSortingBlockInputStream.h Cleanups #4246 2019-02-10 18:17:45 +03:00
processConstants.cpp fix style 2018-10-19 16:04:50 +03:00
processConstants.h fix style 2018-10-19 16:04:50 +03:00
PushingToViewsBlockOutputStream.cpp separate Read and Write lock holders, better method names 2019-03-07 21:10:21 +03:00
PushingToViewsBlockOutputStream.h PushingToViewsBlockOutputStream: process blocks concurrently 2018-09-26 15:22:06 -07:00
RemoteBlockInputStream.cpp add timeouts to remote streams 2019-06-02 12:43:20 +03:00
RemoteBlockInputStream.h add timeouts to remote streams 2019-06-02 12:43:20 +03:00
RemoteBlockOutputStream.cpp add timeouts to remote streams 2019-06-02 12:43:20 +03:00
RemoteBlockOutputStream.h add timeouts to remote streams 2019-06-02 12:43:20 +03:00
ReplacingSortedBlockInputStream.cpp Better stop condition 2019-03-28 14:12:59 +03:00
ReplacingSortedBlockInputStream.h CI Fails fixes and little performance improvement 2019-03-28 11:52:09 +03:00
RollupBlockInputStream.cpp utils/check-style/check-style #3069 2018-09-08 06:07:12 +03:00
RollupBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
SizeLimits.cpp
SizeLimits.h
SquashingBlockInputStream.cpp Fixed error [#CLICKHOUSE-2] 2018-09-09 08:47:27 +03:00
SquashingBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
SquashingBlockOutputStream.cpp Remove redundant changes 2018-09-20 16:26:32 +03:00
SquashingBlockOutputStream.h Strict order of evaluated and added columns 2018-09-20 14:16:15 +03:00
SquashingTransform.cpp Fixed test [#CLICKHOUSE-2] 2018-09-09 05:23:24 +03:00
SquashingTransform.h Preparation [#CLICKHOUSE-2] 2018-09-08 22:23:48 +03:00
SummingSortedBlockInputStream.cpp MergingSortedBlockInputStream class constructor, "max_block_size" parameter: change type UInt64 -> size_t. 2019-02-19 14:56:08 +03:00
SummingSortedBlockInputStream.h MergingSortedBlockInputStream class constructor, "max_block_size" parameter: change type UInt64 -> size_t. 2019-02-19 14:56:08 +03:00
TotalsHavingBlockInputStream.cpp Simplified logic with "IColumn::convertToFullColumnIfConst" (suggested by Amos Bird) [#CLICKHOUSE-2] 2018-12-21 19:00:07 +03:00
TotalsHavingBlockInputStream.h Merge IBlockInputStream and IProfilingBlockInputStream into one 2019-01-23 17:48:50 +03:00
TTLBlockInputStream.cpp TTL for columns and tables (#4212) 2019-04-15 12:30:45 +03:00
TTLBlockInputStream.h TTL for columns and tables (#4212) 2019-04-15 12:30:45 +03:00
UnionBlockInputStream.h add timeouts to remote streams 2019-06-02 12:43:20 +03:00
VersionedCollapsingSortedBlockInputStream.cpp Better stop condition 2019-03-28 14:12:59 +03:00
VersionedCollapsingSortedBlockInputStream.h Move all vertically possible streams to stopcondition 2019-03-26 14:37:32 +03:00