[ 
https://issues.apache.org/jira/browse/CASSANDRA-6454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14002525#comment-14002525
 ] 

Alex Liu commented on CASSANDRA-6454:
-------------------------------------

The latest patch is attached. To use CqlNativeStorage, the following parameters 
need to be specified
{code}
input_cql=     (It must in the following format 
 * 1) select clause must include partition key columns (to calculate the 
progress based on the actual CF row processed)
 * 2) where clause must include token(partition_key1, ...  , partition_keyn) > 
? and 
 *       token(partition_key1, ... , partition_keyn) <= ?  (in the right order) 

native_port=  (If it's not default port)

other parameters are
[&native_port=<native_port>][&core_conns=<core_conns>]
[&max_conns=<max_conns>][&min_simult_reqs=<min_simult_reqs>][&max_simult_reqs=<max_simult_reqs>]
[&native_timeout=<native_timeout>][&native_read_timeout=<native_read_timeout>][&rec_buff_size=<rec_buff_size>]
[&send_buff_size=<send_buff_size>][&solinger=<solinger>][&tcp_nodelay=<tcp_nodelay>]
[&reuse_address=<reuse_address>]
[&keep_alive=<keep_alive>][&auth_provider=<auth_provider>][&trust_store_path=<trust_store_path>]
[&key_store_path=<key_store_path>][&trust_store_password=<trust_store_password>]
[&key_store_password=<key_store_password>][&cipher_suites=<cipher_suites>][&input_cql=<input_cql>]]
{code}


> Pig support for hadoop CqlInputFormat
> -------------------------------------
>
>                 Key: CASSANDRA-6454
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-6454
>             Project: Cassandra
>          Issue Type: Bug
>          Components: Hadoop
>            Reporter: Alex Liu
>            Assignee: Alex Liu
>             Fix For: 2.0.9
>
>         Attachments: 6454-2.0-branch.txt, 6454-v2-2.0-branch.txt
>
>
> CASSANDRA-6311 adds new CqlInputFormat, we need add the Pig support for it



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Reply via email to