| 1311 | } |
| 1312 | |
| 1313 | JoinAlgorithmParams::JoinAlgorithmParams(const Context & context) |
| 1314 | { |
| 1315 | const auto & settings = context.getSettingsRef(); |
| 1316 | |
| 1317 | join_any_take_last_row = settings[Setting::join_any_take_last_row]; |
| 1318 | |
| 1319 | collect_hash_table_stats_during_joins = settings[Setting::collect_hash_table_stats_during_joins]; |
| 1320 | max_entries_for_hash_table_stats = context.getServerSettings()[ServerSetting::max_entries_for_hash_table_stats]; |
| 1321 | hash_table_key_hash = 0; |
| 1322 | parallel_hash_join_threshold = settings[Setting::parallel_hash_join_threshold]; |
| 1323 | |
| 1324 | grace_hash_join_initial_buckets = settings[Setting::grace_hash_join_initial_buckets]; |
| 1325 | grace_hash_join_max_buckets = settings[Setting::grace_hash_join_max_buckets]; |
| 1326 | |
| 1327 | max_size_to_preallocate_for_joins = settings[Setting::max_size_to_preallocate_for_joins]; |
| 1328 | max_threads = settings[Setting::max_threads]; |
| 1329 | |
| 1330 | max_bytes_before_external_join = JoinSettings::getMaxBytesBeforeExternalJoin( |
| 1331 | settings[Setting::max_bytes_before_external_join], |
| 1332 | settings[Setting::max_bytes_ratio_before_external_join]); |
| 1333 | |
| 1334 | initial_query_id = context.getInitialQueryId(); |
| 1335 | lock_acquire_timeout = std::chrono::milliseconds(settings[Setting::lock_acquire_timeout].totalMilliseconds()); |
| 1336 | } |
| 1337 | |
| 1338 | JoinAlgorithmParams::JoinAlgorithmParams( |
| 1339 | const JoinSettings & join_settings, |
nothing calls this directly
no test coverage detected