| 10 | } |
| 11 | |
| 12 | void TTLUpdateInfoAlgorithm::execute(Block & block) |
| 13 | { |
| 14 | if (!block) |
| 15 | return; |
| 16 | |
| 17 | auto ttl_column = executeExpressionAndGetColumn(description.expression, block, description.result_column); |
| 18 | for (size_t i = 0; i < block.rows(); ++i) |
| 19 | { |
| 20 | UInt32 cur_ttl = ITTLAlgorithm::getTimestampByIndex(ttl_column.get(), i); |
| 21 | new_ttl_info.update(cur_ttl); |
| 22 | } |
| 23 | } |
| 24 | |
| 25 | TTLMoveAlgorithm::TTLMoveAlgorithm( |
| 26 | const TTLDescription & description_, const TTLInfo & old_ttl_info_, time_t current_time_, bool force_) |