Cassandra Forward Paging With Spring 2.x

User.java

    public PagedData findUsersByActivationStatusWithPaging(UserActivationStatus activationStatus, String pagingState) {
        logger.info("Finding users by activation status {}...", activationStatus);

        Select select = QueryBuilder
                .select()
                .from("user");
        select.where(eq("activationStatus", activationStatus.name()));
        select.setFetchSize(pagingFetchSize);
        if (pagingState != null) {
            select.setPagingState(PagingState.fromString(pagingState));
        }

        Slice<User> users = cassandraTemplate.slice(select, User.class);

        logger.info("Found {} users with/by activation status {}", users.getContent().size(), activationStatus);

        if(users.hasNext()) {
            CassandraPageRequest next = (CassandraPageRequest) users.nextPageable();
            return new PagedData(next.getPagingState().toString(), users.hasNext(), users.getContent());
        }else{
            return new PagedData(null,false,users.getContent());
        }
    }

thank u so much you saved my life

I want to wait infinitely for new inserts into the table and as soon as the result set equals the batch size, I want to consume it. Can you please let me know how to implement this scenario?