varchar 키를 사용하여 CQL3을 사용하여 Cassandra에서 큰 결과를 페이징

Question

이전 중고품 기반 코드를 CQL3으로 업데이트하고 있습니다.

코드의 한 부분이 20M + 행으로 구성된 테이블의 전체 데이터 세트를 처리하고 있습니다. 이 부분은 처음에는 메모리 사용으로 인해 프로그램이 손상 되었기 때문에 TokenRanges (및 Hector)를 사용하여 열 패밀리를 반복하는 RowIterator 클래스를 만들었습니다.

CQL3을 사용하여 이것을 다시 쓰려고 할 때 데이터를 페이징하는 데 문제가 있습니다. 나는 http://www.datastax.com/documentation/cql/3.0/cql/cql_using/paging_c.html에서 약간의 정보를 통해 찾았지만, 최초의 "페이지"

resultSet = session.execute("select * from " + TABLE + " where token(key) <= token(" + offset + ")"); 

이 코드를하려고 할 때 나는 오류를

com.datastax.driver.core.exceptions.InvalidTypeException를 얻을 : 잘못된 유형을 가 CQL 형 VARCHAR 값 0, 기대 클래스 java.lang.String하지만 클래스 java.lang.Integer의

는

부여 제공된 링크의 예는 숫자 키를 사용한다. varchar (UTF8Type) 키를 사용하여이 작업을 수행 할 수 있습니까?

현재이 기능이 내장되어있는 것 같습니다 (https://issues.apache.org/jira/browse/CASSANDRA-4415). 그러나 저에게 도움이되는 예제를 찾을 수 없습니다. 게다가, 나는 지금 Cassandra 1.2.9를 위해 그것을 해결해야만한다.

Answer 1

따라서 쉬운 대답은 Cassandra 2.0.X로 업그레이드하고 새로운 내장 페이징 기능을 사용하는 것입니다. 그러나 Cassandra 1.2에서이 작업을 수행하려면 올바른 방향으로 가야합니다. 당신의 구문이 작동해야합니다, 만약 당신이 cqlsh에서 시도하는 쿼리를 실행하면 같은 에러가 나옵니까? 이런 식으로 페이징 할 때 ">"를 사용하는 것이 가장 좋으며, 이는 문제 일 수 있습니다. select * from table limit 100부터 시작하여 select * from table where token(key)>token('last key') limit 100

으로 문의하고 싶습니다. 준비된 진술로 시도해 보겠습니다. 문자열 조작은 오프셋에 재미있는 작업을 수행 중일 수 있습니다.