private void dropTable()

in cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/CassandraSessionImpl.java [593:618]

• 26 lines of code
• 4 McCabe index (conditional complexity)

    private void dropTable(String keyspace, String table) {
        String fullName = keyspace + "." + table;
        int attempt = 0;
        Throwable error = null;
        String errorMsg = "Failed to drop Cassandra table '" + fullName + "'";
        RandomSleeper sleeper = newSleeper();
        String statement = "drop table if exists " + fullName;
        while (attempt < CQL_EXECUTION_ATTEMPTS_COUNT) {
            try {
                session().execute(statement);
                return;
            }
            catch (Throwable e) {
                if (CassandraHelper.isHostsAvailabilityError(e)) {
                    handleHostsAvailabilityError(e, attempt, errorMsg);
                }
                else {
                    throw new IgniteException(errorMsg, e);
                }
                error = e;
            }
            sleeper.sleep();
            attempt++;
        }
        throw new IgniteException(errorMsg, error);
    }