incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vivek Mishra <mishra.v...@gmail.com>
Subject Re: Bulk Loader in cassandra : String as row keys in cassandra
Date Fri, 11 Oct 2013 10:47:00 GMT
but i have changed my **key_validation_class=AsciiType** in order to make
**string as row keys**

why not key_validation_class=UTF8Type ?

-Vivek


On Fri, Oct 11, 2013 at 3:55 PM, ashish sanadhya <sanadhyaashu@gmail.com>wrote:

> I have done with bulk loader with key_validation_class=LexicalUUIDType for
> new row with the help of this [code][1] but i have changed my
> **key_validation_class=AsciiType** in order to make **string as row keys**
>
>       create column family Users1
>       with key_validation_class=AsciiType
>        and comparator=AsciiType
>       AND column_metadata = [
>       {column_name: timestamp1, validation_class: AsciiType}
>       {column_name: symbol, validation_class: AsciiType}
>       {column_name: Bid_Price, validation_class:AsciiType}
>       {column_name: Ask_Price, validation_class:AsciiType}
>       ];
>
>
> i have tried all possible changes to code in order to make row keys as
> string type but getting an error or even without **usersWriter.newRow** not
> able to write into sstable
>
>
>       while ((line = reader.readLine()) != null)
>         {
>              if (entry.parse(line, lineNumber))
>             {
>                 //usersWriter.newRow(uuid);
>                 usersWriter.newRow(String.valueOf(lineNumber));
>                 usersWriter.addColumn(bytes("symbol"),
> bytes(entry.symbol), timestamp);
>                 usersWriter.addColumn(bytes("timestamp1"),
> bytes(entry.timestamp1), timestamp);
>                 usersWriter.addColumn(bytes("Bid_Price"),
> bytes(entry.Bid_Price), timestamp);
>                 usersWriter.addColumn(bytes("Ask_Price"),
> bytes(entry.Ask_Price), timestamp);
>             }
>             lineNumber++;
>         }
>
>   getting an error as expected it is only taking **ByteBuffer**
>
>      usersWriter.newRow(String.valueOf(lineNumber));
>                            ^
>      required: ByteBuffer
>      found: String
>      reason: actual argument String cannot be converted to ByteBuffer by
> method invocation  conversion
>
> Any help to make string as row keys in sstable for the above column family
> definition.thanks.
>
>
>
>
>
>
>   [1]:
> http://www.datastax.com/wp-content/uploads/2011/08/DataImportExample.java
>

Mime
View raw message