class CassandraDefaultBucketDAO {

    Mono<Integer> selectRowCount(BlobId blobId) {
        return cassandraAsyncExecutor.executeSingleRow(
                select.bind()
                    .setString(ID, blobId.asString()))
            .map(row -> row.getInt(NUMBER_OF_CHUNK));
    }

    @Inject @VisibleForTesting public  CassandraDefaultBucketDAO(Session session);

}