ClickHouse/src/DataStreams
Nikolai Kochetov 6b619512aa Fix style.
2021-10-06 12:37:56 +03:00
..
examples move to examples everywhere 2021-04-27 01:51:42 +03:00
tests Maybe fix some build. 2021-09-17 15:05:54 +03:00
AsynchronousBlockInputStream.cpp
AsynchronousBlockInputStream.h Fix half of typos 2020-08-08 03:47:03 +03:00
BlockIO.cpp Maybe fix some build. 2021-09-17 15:05:54 +03:00
BlockIO.h Small refactoring. 2021-09-15 22:35:48 +03:00
BlockStreamProfileInfo.cpp Add PullingPipelineExecutor. 2020-05-15 00:03:38 +03:00
BlockStreamProfileInfo.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
CheckConstraintsBlockOutputStream.cpp Fix style. 2021-09-10 17:54:42 +03:00
CheckConstraintsBlockOutputStream.h Refactor some code. 2021-09-09 16:59:15 +03:00
CMakeLists.txt move to examples everywhere 2021-04-27 01:51:42 +03:00
ColumnGathererStream.cpp Fix style. 2021-10-06 12:37:56 +03:00
ColumnGathererStream.h Fix style. 2021-10-06 12:37:56 +03:00
ConnectionCollector.cpp Rename "common" to "base" 2021-10-02 10:13:14 +03:00
ConnectionCollector.h Use shared_ptr for connections 2021-07-21 19:56:32 +08:00
ConvertingBlockInputStream.cpp Block structure mismatch is a program error 2020-07-28 21:35:18 +03:00
ConvertingBlockInputStream.h
copyData.cpp Add copyData() with std::atomic and progress callback 2021-04-14 23:15:31 +03:00
copyData.h Add copyData() with std::atomic and progress callback 2021-04-14 23:15:31 +03:00
CountingBlockOutputStream.cpp Comment debug output. 2021-09-08 21:30:54 +03:00
CountingBlockOutputStream.h Refactor some code. 2021-09-09 16:59:15 +03:00
DistinctSortedBlockInputStream.cpp Remove SortDescription from IBlockInputStream. 2020-07-21 11:05:52 +03:00
DistinctSortedBlockInputStream.h Remove SortDescription from IBlockInputStream. 2020-07-21 11:05:52 +03:00
ExecutionSpeedLimits.cpp Rename "common" to "base" 2021-10-02 10:13:14 +03:00
ExecutionSpeedLimits.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
ExpressionBlockInputStream.cpp Remove Join from ExpressionActions. 2020-09-08 13:40:53 +03:00
ExpressionBlockInputStream.h Remove Join from ExpressionActions. 2020-09-08 13:40:53 +03:00
finalizeBlock.cpp
finalizeBlock.h
formatBlock.cpp Updated TableFunctionExecutable 2021-08-25 22:30:22 +03:00
formatBlock.h Updated TableFunctionExecutable 2021-08-25 22:30:22 +03:00
IBlockInputStream.cpp Less clock_gettime calls 2021-08-06 17:38:55 +02:00
IBlockInputStream.h Merge branch 'async-insert' of git://github.com/abyss7/ClickHouse into merging-20557 2021-08-06 16:20:02 +03:00
IBlockOutputStream.h Fix test 2021-02-26 18:47:57 +03:00
IBlockStream_fwd.h
InternalTextLogsRowOutputStream.cpp Rename "common" to "base" 2021-10-02 10:13:14 +03:00
InternalTextLogsRowOutputStream.h Remove useless files 2021-04-13 23:04:13 +03:00
ITTLAlgorithm.cpp minor changes near TTL computation 2021-01-12 19:42:49 +03:00
ITTLAlgorithm.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
MarkInCompressedFile.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
materializeBlock.cpp
materializeBlock.h
MaterializingBlockInputStream.cpp
MaterializingBlockInputStream.h
MaterializingBlockOutputStream.h
MongoDBSource.cpp Rename "common" to "base" 2021-10-02 10:13:14 +03:00
MongoDBSource.h Removed some data streams 2021-08-11 23:39:01 +03:00
narrowBlockInputStreams.cpp Fix some problems introduced by refactoring. 2020-10-12 17:58:09 +08:00
narrowBlockInputStreams.h Remove some code 2021-07-17 21:06:46 +03:00
NativeBlockInputStream.cpp Rename "common" to "base" 2021-10-02 10:13:14 +03:00
NativeBlockInputStream.h implement nested with multiple nesting 2020-11-21 20:27:42 +03:00
NativeBlockOutputStream.cpp Move protocol macros into separate header 2021-10-03 14:34:03 +03:00
NativeBlockOutputStream.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
NullAndDoCopyBlockInputStream.h Restore missing file 2021-06-28 23:04:14 +03:00
NullBlockOutputStream.h
OneBlockInputStream.h Cleanups 2020-10-10 19:31:10 +03:00
OwningBlockInputStream.h
ParallelInputsProcessor.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
PostgreSQLSource.cpp Rename "common" to "base" 2021-10-02 10:13:14 +03:00
PostgreSQLSource.h Removed some data streams 2021-08-11 23:39:01 +03:00
PushingToViewsBlockOutputStream.cpp Rename "common" to "base" 2021-10-02 10:13:14 +03:00
PushingToViewsBlockOutputStream.h Refactor pushing to views. 2021-09-22 13:57:00 +03:00
RemoteBlockInputStream.cpp Merge pull request #25674 from amosbird/distributedreturnconnection 2021-07-22 11:04:49 +03:00
RemoteBlockInputStream.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
RemoteBlockOutputStream.cpp Rename "common" to "base" 2021-10-02 10:13:14 +03:00
RemoteBlockOutputStream.h Rewrite PushingToViewsBlockOutputStream part 6 2021-09-03 20:29:36 +03:00
RemoteQueryExecutor.cpp Pass through initial query_id for clickhouse-benchmark 2021-09-25 18:05:55 +03:00
RemoteQueryExecutor.h Drop unused headers 2021-09-01 02:47:52 +03:00
RemoteQueryExecutorReadContext.cpp Fix data-race between setConnectionFD() and setTimer() from cancellation path 2021-08-25 09:42:30 +03:00
RemoteQueryExecutorReadContext.h Fix data-race between setConnectionFD() and setTimer() from cancellation path 2021-08-25 09:42:30 +03:00
ShellCommandSource.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
SizeLimits.cpp Preparation for structured logging 2020-05-31 00:35:52 +03:00
SizeLimits.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
SQLiteSource.cpp Rename "common" to "base" 2021-10-02 10:13:14 +03:00
SQLiteSource.h Fixed SQLiteSource 2021-08-13 00:58:24 +03:00
SquashingBlockInputStream.cpp
SquashingBlockInputStream.h
SquashingBlockOutputStream.cpp
SquashingBlockOutputStream.h
SquashingTransform.cpp Fix some more tests. 2021-09-09 14:16:03 +03:00
SquashingTransform.h
StreamLocalLimits.h Review fixes. 2020-09-15 13:40:39 +03:00
TemporaryFileStream.cpp Move protocol macros into separate header 2021-10-03 14:34:03 +03:00
TemporaryFileStream.h Add module part for TemporaryFileStream.h 2021-10-03 14:34:03 +03:00
TTLAggregationAlgorithm.cpp Merge pull request #25743 from ClickHouse/fix_aggregation_ttl 2021-07-07 10:49:16 +03:00
TTLAggregationAlgorithm.h Improve implementation 2021-05-21 04:17:18 +03:00
TTLBlockInputStream.cpp materialize ttl recalculate only optional 2021-08-04 22:16:13 +08:00
TTLBlockInputStream.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
TTLCalcInputStream.cpp materialize ttl recalculate only optional 2021-08-04 22:16:13 +08:00
TTLCalcInputStream.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00
TTLColumnAlgorithm.cpp materialize ttl recalculate only optional 2021-08-04 22:16:13 +08:00
TTLColumnAlgorithm.h materialize ttl recalculate only optional 2021-08-04 22:16:13 +08:00
TTLDeleteAlgorithm.cpp Review bug fixes 2021-07-06 15:05:58 +03:00
TTLDeleteAlgorithm.h add comments and test for compatibility 2021-01-28 02:39:15 +03:00
TTLUpdateInfoAlgorithm.cpp materialize ttl recalculate only optional 2021-08-04 22:16:13 +08:00
TTLUpdateInfoAlgorithm.h materialize ttl recalculate only optional 2021-08-04 22:16:13 +08:00
UnionBlockInputStream.h Rename "common" to "base" 2021-10-02 10:13:14 +03:00