class StatementExecutor {

  void handleRestoration(final RestoreCommands restoreCommands) throws Exception {
    restoreCommands.forEach(
        (commandId, command, terminatedQueries, wasDropped) -> {
          log.info("Executing prior statement: '{}'", command);
          try {
            handleStatementWithTerminatedQueries(
                command,
                commandId,
                terminatedQueries,
                wasDropped
            );
          } catch (Exception exception) {
            log.warn(
                "Failed to execute statement due to exception",
                exception
            );
          }
        }
    );
  }

  public  StatementExecutor(
      KsqlEngine ksqlEngine,
      StatementParser statementParser
  );

}