thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-15 02:41:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

add column timestamp only when function now is used

Browse Source
This commit is contained in:
Vxider 2020-07-13 22:28:31 +08:00
parent 14150d452b
commit fcdb930c64
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Storages/WindowView/StorageWindowView.cpp
View File

@ -996,9 +996,9 @@ void StorageWindowView::writeIntoWindowView(StorageWindowView & window_view, con
if (window_view.is_proctime)
{
fire_signal_lock = std::shared_lock<std::shared_mutex>(window_view.fire_signal_mutex);
UInt32 timestamp_now = std::time(nullptr);
pipe.addSimpleTransform(std::make_shared<AddingConstColumnTransform<UInt32>>(
pipe.getHeader(), std::make_shared<DataTypeDateTime>(), timestamp_now, "____timestamp"));
if (window_view.is_time_column_func_now)
pipe.addSimpleTransform(std::make_shared<AddingConstColumnTransform<UInt32>>(
pipe.getHeader(), std::make_shared<DataTypeDateTime>(), std::time(nullptr), "____timestamp"));
InterpreterSelectQuery select_block(window_view.getMergeableQuery(), context, {std::move(pipe)}, QueryProcessingStage::WithMergeableState);
source_stream = select_block.execute().getInputStream();