public Future<Integer> atomicDeleteSinkTable(ExecutorService executor) {
        String sql = " DELETE FROM " + this.getSinkTableName();
        LOG.info("Atomic and asynchronous deletion of all data from the sink table with this command: " + sql);

        return executor.submit(() -> {
            Statement statement = this.getConnection().createStatement();
            statement.executeUpdate(sql);
            statement.close();
            // Do not commit this transaction
            return 0;
        });
    }
Delete all rows of a sink table within a transaction asynchronously, in a complete-atomic mode

@param executor the executor service for delete rows asynchronously in a task.
@return the Future of the task.
src/main/java/org/replicadb/manager/SqlManager.java