[
https://issues.apache.org/jira/browse/CASSANDRA-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13921141#comment-13921141
]
Alex Liu commented on CASSANDRA-6311:
-------------------------------------
1. validation of input CQL query needs parsing the query which is what we are
trying to avoid.
2. AbstractIterator is to always return to the local host (so that the task is
only read data from local host ), it doesn't return endOfData(). It's using
stickHost, a host name, to get the Host object which can't be directly created
due to the class is not public class. The Host object, origHost, is obtained
from cluster internal code. It's possible that origHost object can be null
which case the stickHost is not in the cluster. In that case we don't want the
job to run for it's in the wrong host.
3. I clean up the code according to other notes.
Attach v6 version.
> Add CqlRecordReader to take advantage of native CQL pagination
> --------------------------------------------------------------
>
> Key: CASSANDRA-6311
> URL: https://issues.apache.org/jira/browse/CASSANDRA-6311
> Project: Cassandra
> Issue Type: New Feature
> Components: Hadoop
> Reporter: Alex Liu
> Assignee: Alex Liu
> Fix For: 2.0.6
>
> Attachments: 6311-v3-2.0-branch.txt, 6311-v4.txt,
> 6311-v5-2.0-branch.txt, 6331-2.0-branch.txt, 6331-v2-2.0-branch.txt
>
>
> Since the latest Cql pagination is done and it should be more efficient, so
> we need update CqlPagingRecordReader to use it instead of the custom thrift
> paging.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
