class SchemaHelper {

    boolean areSchemasAligned(long schemaAlignmentDelayMillis)
    {
        LOG.info("Waiting for schema to align in cluster");

        int delayMillis = 0;
        while (areLiveNodesWaitingOnSchemaUpdate())
        {
            if (delayMillis >= schemaAlignmentDelayMillis)
            {
                return false;
            }
            delayMillis += retryIntervalMillis;

            try
            {
                Thread.sleep(retryIntervalMillis);
            }
            catch (InterruptedException e)
            {
                Thread.currentThread().interrupt();
                return false;
            }
        }

        return true;
    }

      SchemaHelper();
    @VisibleForTesting  SchemaHelper(InetAddress localAddress, Gossiper gossiper, long retryIntervalMillis);

}