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:36 GMT
Also, please use ByteBufferUtils for byte conversions.


On Fri, Oct 11, 2013 at 4:17 PM, Vivek Mishra <mishra.vivs@gmail.com> wrote:

> 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