class CassandraRecipientRewriteTableDAO {

    public Flux<Pair<MappingSource, Mapping>> getAllMappings() {
        return executor.executeRows(retrieveAllMappingsStatement.bind())
            .map(row -> Pair.of(
                MappingSource.fromUser(row.getString(USER), row.getString(DOMAIN)),
                Mapping.of(row.getString(MAPPING))));
    }

    @Inject public  CassandraRecipientRewriteTableDAO(Session session, CassandraUtils cassandraUtils);

}