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

Alex Liu commented on CASSANDRA-6927:
-------------------------------------

v2 on cassandra-2.0 branch is attached. It change the interface from 
OutputFormat<ByteBuffer,List<Mutation>> to OutputFormat<Object, List<Mutation>> 
where Object is a placeholder for an object, but internally it's not used, so 
it can just be null object. List<Mutation> is the binder variable values to the 
insert statement.

I also remove the "." + columnFamily  in
{code}
    private String getColumnFamilySchema()
    {
        return conf.get(COLUMNFAMILY_SCHEMA + "." + columnFamily);
    }
    
    private String getColumnFamilyInsertStatement()
    {
        return conf.get(COLUMNFAMILY_INSERT_STATEMENT + "." + columnFamily);
    }
{code}

and some code format clean up

> Create a CQL3 based bulk OutputFormat
> -------------------------------------
>
>                 Key: CASSANDRA-6927
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-6927
>             Project: Cassandra
>          Issue Type: New Feature
>          Components: Hadoop
>            Reporter: Paul Pak
>            Priority: Minor
>              Labels: cql3, hadoop
>         Attachments: 6927-2.0-branch-v2.txt, trunk-6927.txt
>
>
> This is the CQL compatible version of BulkOutputFormat.  CqlOutputFormat 
> exists, but doesn't write SSTables directly, similar to 
> ColumnFamilyOutputFormat for thrift.



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

Reply via email to