[
https://issues.apache.org/jira/browse/CASSANDRA-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14034441#comment-14034441
]
Alex Liu edited comment on CASSANDRA-6927 at 6/17/14 9:54 PM:
--------------------------------------------------------------
v2 on cassandra-2.0 branch is attached. It changes 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
was (Author: alexliu68):
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)
