ClickHouse/src/DataStreams
alexey-milovidov dc3ffd3fe2
Merge pull request #19451 from azat/safe-writes
Do not silently ignore write errors
2021-02-11 21:19:11 +03:00
..
tests Cleanups 2020-10-10 19:31:10 +03:00
AddingDefaultBlockOutputStream.cpp Review fixes. 2021-02-10 15:45:39 +03:00
AddingDefaultBlockOutputStream.h Review fixes. 2021-02-10 15:45:39 +03:00
AddingDefaultsBlockInputStream.cpp Rename functions. 2021-02-05 18:11:26 +03:00
AddingDefaultsBlockInputStream.h Recursive defaults 2020-10-02 15:38:50 +03:00
AsynchronousBlockInputStream.cpp dbms/ → src/ 2020-04-03 18:14:31 +03:00
AsynchronousBlockInputStream.h Fix half of typos 2020-08-08 03:47:03 +03:00
BlockIO.cpp Refactor Pipe [part 6] 2020-08-06 15:24:05 +03:00
BlockIO.h Fix result_rows and result_bytes metrics for selects. 2020-07-02 17:51:10 +03:00
BlocksListBlockInputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
BlocksSource.h Check for #pragma once in headers 2020-10-10 21:37:02 +03:00
BlockStreamProfileInfo.cpp Add PullingPipelineExecutor. 2020-05-15 00:03:38 +03:00
BlockStreamProfileInfo.h Try speedup build (#14809) 2020-09-15 12:55:57 +03:00
CheckConstraintsBlockOutputStream.cpp Merge branch 'master' into actions-dag-f14 2020-11-12 11:54:44 +03:00
CheckConstraintsBlockOutputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
CheckSortedBlockInputStream.cpp Better exception message in CheckingSortedBlockInputStream 2020-07-20 17:57:01 +03:00
CheckSortedBlockInputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
CMakeLists.txt dbms/ → src/ 2020-04-03 18:14:31 +03:00
ColumnGathererStream.cpp More checks in writer wide 2021-01-11 15:03:00 +03:00
ColumnGathererStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
ConvertingBlockInputStream.cpp Block structure mismatch is a program error 2020-07-28 21:35:18 +03:00
ConvertingBlockInputStream.h Remove useless code 2020-04-15 00:05:45 +03:00
copyData.cpp Insert select using PipelineExecutor. 2020-05-27 21:20:26 +03:00
copyData.h Insert select using PipelineExecutor. 2020-05-27 21:20:26 +03:00
CountingBlockOutputStream.cpp dbms/ → src/ 2020-04-03 18:14:31 +03:00
CountingBlockOutputStream.h dbms/ → src/ 2020-04-03 18:14:31 +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 Whitespace 2020-05-29 23:17:38 +03:00
ExecutionSpeedLimits.h Try speedup build (#14809) 2020-09-15 12:55:57 +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 Make IColumn::mutate() static. 2020-05-14 11:30:18 +03:00
finalizeBlock.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
IBlockInputStream.cpp remove more stringstreams 2020-11-10 21:22:26 +03:00
IBlockInputStream.h remove more stringstreams 2020-11-10 21:22:26 +03:00
IBlockOutputStream.h Do not catch exceptions during final flush in writers destructors 2021-02-05 01:31:45 +03:00
IBlockStream_fwd.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
InputStreamFromASTInsertQuery.cpp Recursive defaults 2020-10-02 15:38:50 +03:00
InputStreamFromASTInsertQuery.h Really atomic metadata 2020-06-18 14:02:31 +03:00
InternalTextLogsRowOutputStream.cpp Merge pull request #10445 from azat/logger-source-coloring-client 2020-04-23 00:35:40 +03:00
InternalTextLogsRowOutputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
ITTLAlgorithm.cpp minor changes near TTL computation 2021-01-12 19:42:49 +03:00
ITTLAlgorithm.h add comments and test for compatibility 2021-01-28 02:39:15 +03:00
LazyBlockInputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
LimitBlockInputStream.cpp dbms/ → src/ 2020-04-03 18:14:31 +03:00
LimitBlockInputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
MarkInCompressedFile.h Try speedup build (#14809) 2020-09-15 12:55:57 +03:00
materializeBlock.cpp dbms/ → src/ 2020-04-03 18:14:31 +03:00
materializeBlock.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
MaterializingBlockInputStream.cpp dbms/ → src/ 2020-04-03 18:14:31 +03:00
MaterializingBlockInputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
MaterializingBlockOutputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
MergingSortedBlockInputStream.cpp Rename getPos to getRow, change mergeBlock, pass setting instead of context 2020-12-04 19:25:30 +03:00
MergingSortedBlockInputStream.h Fix half of typos 2020-08-08 03:47:03 +03:00
MongoDBBlockInputStream.cpp remove more stringstreams 2020-11-10 21:22:26 +03:00
MongoDBBlockInputStream.h Add comment 2020-06-26 17:34:37 +03:00
narrowBlockInputStreams.cpp Fix some problems introduced by refactoring. 2020-10-12 17:58:09 +08:00
narrowBlockInputStreams.h Fix some problems introduced by refactoring. 2020-10-12 17:58:09 +08:00
NativeBlockInputStream.cpp Merge remote-tracking branch 'upstream/master' into HEAD 2020-12-25 21:25:59 +03:00
NativeBlockInputStream.h implement nested with multiple nesting 2020-11-21 20:27:42 +03:00
NativeBlockOutputStream.cpp dbms/ → src/ 2020-04-03 18:14:31 +03:00
NativeBlockOutputStream.h Try speedup build (#14809) 2020-09-15 12:55:57 +03:00
NullAndDoCopyBlockInputStream.h Insert select using PipelineExecutor. 2020-05-27 21:20:26 +03:00
NullBlockInputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
NullBlockOutputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
OneBlockInputStream.h Cleanups 2020-10-10 19:31:10 +03:00
OwningBlockInputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
ParallelInputsProcessor.h Fix some problems introduced by refactoring. 2020-10-12 17:58:09 +08:00
PostgreSQLBlockInputStream.cpp Fix 2021-01-11 10:55:38 +00:00
PostgreSQLBlockInputStream.h Fix 2021-01-11 10:55:38 +00:00
PushingToViewsBlockOutputStream.cpp Change PushingToViewsBlockOutputStream::process, to accept ref to ViewInfo 2021-02-04 00:44:24 +03:00
PushingToViewsBlockOutputStream.h Change PushingToViewsBlockOutputStream::process, to accept ref to ViewInfo 2021-02-04 00:44:24 +03:00
RemoteBlockInputStream.cpp More forward declaration for generic headers 2020-12-12 17:43:10 +03:00
RemoteBlockInputStream.h More forward declaration for generic headers 2020-12-12 17:43:10 +03:00
RemoteBlockOutputStream.cpp compile 2020-11-18 20:44:33 +03:00
RemoteBlockOutputStream.h Forward declaration for Context as much as possible. 2020-05-21 01:53:18 +03:00
RemoteQueryExecutor.cpp More isolated code 2021-02-05 12:54:34 +03:00
RemoteQueryExecutor.h More isolated code 2021-02-05 12:54:34 +03:00
RemoteQueryExecutorReadContext.cpp Fix leaking of pipe fd for async_socket_for_remote 2021-01-16 01:57:36 +03:00
RemoteQueryExecutorReadContext.h Fix leaking of pipe fd for async_socket_for_remote 2021-01-16 01:57:36 +03:00
SizeLimits.cpp Preparation for structured logging 2020-05-31 00:35:52 +03:00
SizeLimits.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
SquashingBlockInputStream.cpp less copying 2020-04-21 17:59:57 +03:00
SquashingBlockInputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
SquashingBlockOutputStream.cpp less copying 2020-04-21 17:59:57 +03:00
SquashingBlockOutputStream.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
SquashingTransform.cpp Fix trailing whitespace 2020-10-26 22:12:40 +03:00
SquashingTransform.h Update SquashingTransform.h 2020-04-21 19:27:56 +03:00
StreamLocalLimits.h Review fixes. 2020-09-15 13:40:39 +03:00
TemporaryFileStream.h straighten the protocol version 2020-09-17 17:37:29 +03:00
TTLAggregationAlgorithm.cpp minor changes near TTL computation 2021-01-12 19:42:49 +03:00
TTLAggregationAlgorithm.h add comments and test for compatibility 2021-01-28 02:39:15 +03:00
TTLBlockInputStream.cpp fix TTLs with WHERE 2021-01-13 17:04:27 +03:00
TTLBlockInputStream.h refactoring of TTL stream 2020-12-25 18:46:13 +03:00
TTLColumnAlgorithm.cpp minor changes near TTL computation 2021-01-12 19:42:49 +03:00
TTLColumnAlgorithm.h add comments and test for compatibility 2021-01-28 02:39:15 +03:00
TTLDeleteAlgorithm.cpp minor changes near TTL computation 2021-01-12 19:42:49 +03:00
TTLDeleteAlgorithm.h add comments and test for compatibility 2021-01-28 02:39:15 +03:00
TTLUpdateInfoAlgorithm.cpp minor changes near TTL computation 2021-01-12 19:42:49 +03:00
TTLUpdateInfoAlgorithm.h add comments and test for compatibility 2021-01-28 02:39:15 +03:00
UnionBlockInputStream.h Remove namespace pollution 2020-05-31 00:57:37 +03:00
ya.make Merge remote-tracking branch 'upstream/master' into HEAD 2021-01-27 19:48:55 +03:00
ya.make.in Fix Arcadia 2021-01-07 06:45:12 +03:00