diff --git a/db/system_keyspace.cc b/db/system_keyspace.cc index 9c050aa676..0d1bf3035a 100644 --- a/db/system_keyspace.cc +++ b/db/system_keyspace.cc @@ -1314,16 +1314,6 @@ typedef std::unordered_map truncation_map; static constexpr uint8_t current_version = 1; -/** - * This method is used to remove information about truncation time for specified column family - */ -future<> remove_truncation_record(utils::UUID id) { - sstring req = format("DELETE * from system.{} WHERE table_uuid = ?", TRUNCATED); - return qctx->qp().execute_internal(req, {id}).discard_result().then([] { - return force_blocking_flush(TRUNCATED); - }); -} - static future get_truncation_record(utils::UUID cf_id) { sstring req = format("SELECT * from system.{} WHERE table_uuid = ?", TRUNCATED); return qctx->qp().execute_internal(req, {cf_id}).then([cf_id](::shared_ptr rs) { @@ -1535,12 +1525,6 @@ template future<> update_peer_info(gms::inet_address ep, sstring column template future<> update_peer_info(gms::inet_address ep, sstring column_name, utils::UUID); template future<> update_peer_info(gms::inet_address ep, sstring column_name, net::inet_address); -future<> update_hints_dropped(gms::inet_address ep, utils::UUID time_period, int value) { - // with 30 day TTL - sstring req = format("UPDATE system.{} USING TTL 2592000 SET hints_dropped[ ? ] = ? WHERE peer = ?", PEER_EVENTS); - return execute_cql(req, time_period, value, ep.addr()).discard_result(); -} - future<> set_scylla_local_param(const sstring& key, const sstring& value) { sstring req = format("UPDATE system.{} SET value = ? WHERE key = ?", SCYLLA_LOCAL); return execute_cql(req, value, key).discard_result(); diff --git a/db/system_keyspace.hh b/db/system_keyspace.hh index ad66b3422e..e43bb8f753 100644 --- a/db/system_keyspace.hh +++ b/db/system_keyspace.hh @@ -203,8 +203,6 @@ future<> update_peer_info(gms::inet_address ep, sstring column_name, Value value future<> remove_endpoint(gms::inet_address ep); -future<> update_hints_dropped(gms::inet_address ep, utils::UUID time_period, int value); - future<> set_scylla_local_param(const sstring& key, const sstring& value); future> get_scylla_local_param(const sstring& key); @@ -414,7 +412,6 @@ enum class bootstrap_state { future<> save_truncation_record(utils::UUID, db_clock::time_point truncated_at, db::replay_position); future<> save_truncation_record(const column_family&, db_clock::time_point truncated_at, db::replay_position); - future<> remove_truncation_record(utils::UUID); future get_truncated_position(utils::UUID); future get_truncated_position(utils::UUID, uint32_t shard); future get_truncated_at(utils::UUID);