docs: public void flush() throws ExecutionException, InterruptedException {
          for (int i = m_firstPartitionTable; i <= m_lastPartitionTable; i++) {
              m_partitionTable[i].flushAllTableQueues();
          }
      }