gmane.comp.db.hector.user

Hector Mutator

Leandro Rodrigues Silva — 2013-05-20T12:56:20

Hello everybody!

I'm using hector for insert columns in runtime on cassandra. But this 
columns don't appear in metadata, so i need to retrieve that columns. It's 
possible?

follow my code:

 Keyspace keyspace = HFactory.createKeyspace(getDefaultKeySpace(), cluster);
        Mutator<String> mutator = HFactory.createMutator(keyspace, 
StringSerializer.get(), new BatchSizeHint(1, keyValuePairs.size()));
        for (Map.Entry<String, Object> entry : keyValuePairs.entrySet()) {
            String property = entry.getKey();
            Object value = entry.getValue();
            HColumn<String, Object> column = createColumn(property, value, 
StringSerializer.get(), new TypeConverterSerializer<Object>(value));
            mutator.addInsertion(key, colFamily, column);
        }
        mutator.execute();


any ideas??

thanks!!

Re: How to retrieve data from cassandra

Ashu Gupta — 2013-05-20T06:00:42

Thanx Nate
Is this the only way? because I have already ported my sql database to 
cassandra. Do I need to run the complete procedure again after storing that 
extra marker to denote the type? And suppose I have done that ,now how 
should I check that extra byte while retrieving rows?

On Friday, 17 May 2013 02:00:44 UTC+5:30, Nate McCall wrote:

Re: How to retrieve data from cassandra

Nate McCall — 2013-05-16T20:30:44

You will need to store a marker of some sort denoting the type either
on the column name of the column value. Using composites for this
would be a good idea. DynamicComposite would effectively give you this
for free, but they are slightly more complicated.

On Thu, May 16, 2013 at 1:11 AM, Ashu Gupta <gupta.ashu1602-Re5JQEeQqe8AvxtiuMwx3w< at >public.gmane.org> wrote:

How to retrieve data from cassandra

Ashu Gupta — 2013-05-16T06:11:34

I am working on cassandra 1.2.3 and using hector 1.1-3 When I fetch columns 
using SliceQuery, it returns me all the columns with the same datatype. Is 
there any way that QueryResult have object as the datatype of column 
values? If I use bytebuffer , So if I want to return multiple columns 
containing different data types(as a wrapper method over Hector), what data 
type do I return from my wrapper method?? I obviously won't know which 
column will have which data type & I can't return ByteBuffer as a generic 
column value type. Can anyone help me out with this?

HUnavailableException: : May not be enough replicas present to handle consistency level.

Codevally — 2013-05-16T07:10:38

Hi

I have 4 nodes Cassandra cluster in production with 1.0.11 version (hector 
1.0.5).

Keyspace: MessageCache:
  Replication Strategy: org.apache.cassandra.locator.SimpleStrategy
  Durable Writes: true
    Options: [replication_factor:4]
  Column Families:
    ColumnFamily: MessageData
      Key Validation Class: org.apache.cassandra.db.marshal.BytesType
      Default column value validator: 
org.apache.cassandra.db.marshal.BytesType
      Columns sorted by: org.apache.cassandra.db.marshal.BytesType
      Row cache size / save period in seconds / keys to save : 0.0/0/all
      Row Cache Provider: 
org.apache.cassandra.cache.ConcurrentLinkedHashCacheProvider
      Key cache size / save period in seconds: 20000.0/3600
      GC grace seconds: 3600
      Compaction min/max thresholds: 4/32
      Read repair chance: 1.0
      Replicate on write: true
      Bloom Filter FP chance: default
      Built indexes: []
      Compaction Strategy: 
org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy

To incre

Row Level Isolation

2013-05-15T18:39:31

I am new to Cassandra and have been using the Hector Template API's. My 
question here is how do I use Row Level Isolation when I am trying to 
update. 

My typical get looks something like:

* public* String getAttributeValueForKey( String columnName, String key ) *
throws* StoreException {


        String result = *null*;

        *try* {

            ColumnFamilyResult<String, String> columnFamilyResult = 
getTemplate().queryColumns( key );

            *if*( *null* != columnFamilyResult ) {

                result = columnFamilyResult.getString( columnName );

            }

        }

        *catch*( HectorException e ) {

            *LOGGER*.error( e );

            *throw* *new* StoreException( e );

        }


        *return* result;

    }


And the puts looks something like:

*  public* *void* putKeyWithValuesAndTimeout( String rowKey, Map<String, 
String> columns, *long* timeInMilliSeconds ) *throws* StoreException {


        ColumnFamilyUpdater<String, String> updater = 
getTemplate().creat

[Firebrand] - MappedCollection objects on WHERE clauses

Rafael Neves — 2013-05-15T16:53:25

Hi people,

I trying using a object annotated with < at >MappedCollection on WHERE clausre 
of my SELECT.

this is possible? how?

SELECT * FROM ColumnFamilys WHERE ColumnFamilys .dinamycColumn.nomeColuna = 
'estoque2'";

class:ColumnFamilys 
public class ColumnFamilys
{
< at >Key
private String id;

private String name;

< at >MappedCollection(lazy=false)
private List<DinamycColumn> dinamycColumns;
...
}

Re: Hector Object Mapper

Wei Zhu — 2013-05-14T19:17:51

Make sure Central Maven is in your repo list. 

http://mvnrepository.com/artifact/org.hectorclient/hector/1.1-3 

-Wei 

----- Original Message -----

From: "Leandro Rodrigues Silva" <leandroleo02-Re5JQEeQqe8AvxtiuMwx3w< at >public.gmane.org> 
To: hector-users-/JYPxA39Uh5TLH3MbocFFw< at >public.gmane.org 
Sent: Tuesday, May 14, 2013 7:24:42 AM 
Subject: Hector Object Mapper 

Hello guys!!! 

I'm trying to use the Hector Object Mapper, but i can't find the link of the download. When i configure que POM, the maven can't find the dependency. This is my configuration: 

<dependency> 
<groupId>org.hectorclient</groupId> 
<artifactId>hector</artifactId> 
<version>1.1-3</version> 
</dependency> 

This is right? 

Any ideas? 

Thanks a lot!

Hector Object Mapper

Leandro Rodrigues Silva — 2013-05-14T14:24:42

Hello guys!!!

I'm trying to use the Hector Object Mapper, but i can't find the link of 
the download. When i configure que POM, the maven can't find the 
dependency. This is my configuration:

<dependency>
<groupId>org.hectorclient</groupId>
<artifactId>hector</artifactId>
<version>1.1-3</version>
</dependency>


This is right?


Any ideas?

Thanks a lot!

Re: Firebrind OCM

Rafael Neves — 2013-05-14T14:22:51

thanks for u help, this solved my problem!

I trying using firebrand on new project and I need more documentation about
this framework.

:)


2013/5/14 Raul Raja Martinez <raulraja-Re5JQEeQqe8AvxtiuMwx3w< at >public.gmane.org>

Re: Firebrind OCM

Raul Raja Martinez — 2013-05-14T13:56:45

try primaryKey("KEY", ColumnDataType.TEXT)


On Tue, May 14, 2013 at 3:08 PM, Rafael Neves <raneves.mg-Re5JQEeQqe8AvxtiuMwx3w< at >public.gmane.org> wrote:

Re: Firebrind OCM

Rafael Neves — 2013-05-14T13:08:15

this method "getColumns" functionally normal if is using on Column Family
created by Cassandra-cli, but don't work for column family created by
method createColumnFamily of Firebrand :(


2013/5/14 Rafael Neves <raneves.mg-Re5JQEeQqe8AvxtiuMwx3w< at >public.gmane.org>

Re: Firebrind OCM

Rafael Neves — 2013-05-14T12:39:30

Raul,

I have this code now:

persistenceFactory.executeQuery(Integer.class, Query.get(createColumnFamily(
columnFamily("LastTest"),
    columnDefinitions(
        primaryKey("key_validation_class", ColumnDataType.TEXT),
        column("testDesc", ColumnDataType.TEXT)
    ),
    storageOptions(
        storageOption(StorageParameter.COMMENT, "comment"),
        storageOption(StorageParameter.READ_REPAIR_CHANCE, "1")
    )
)));
 persistenceFactory.executeQuery(Integer.class, Query.get(createIndex(
onColumnFamily("LastTest"),

column("testDesc")
)));
persistenceFactory.getColumns("LastTest",
"b25b4b70-bbd2-11e2-8f3e-90b11cf59ca2",true, "testDesc");

and the problem persist!
I have chamnge the type of primaryKey for ColumnDataType.TEXT) but don't
solved my problem.
I get the same error:
Exception in thread "main"
me.prettyprint.hector.api.exceptions.HInvalidRequestException:
InvalidRequestException(why:No indexed columns present in by-columns clause
with "equals" operator)



2013/5/14 Raul Raja Martinez <raulr

Re: Firebrind OCM

Raul Raja Martinez — 2013-05-14T07:46:02

Rafael, This is more of a firebrand question than related to Hector. I will
answer it here though but feel free to post any other question related to
FirebrandOCM at https://github.com/47deg/firebrand/issues

The PersistenceFactory.getColumns method assumes you are using mapped
objects and uses KEY as the key name to lookup columns, it also uses
default key validation UTF8 instead of UUID.

If you change it to… primaryKey("KEY", ColumnDataType.TEXT) it should work.
Also I believe you don't need the index unless you plan on querying based
on criteria on those columns.

You can simply consider using the mapper to map those columns to a bean and
simply use the "persist" and "get" methods to transparently save and
retrieve objects

Entity entity = ...;entity.setName(name);persistenceFactory.persist(entity)

Entity entity = peristenceFactory.get(Entity.class, key);





On Mon, May 13, 2013 at 7:54 PM, Rafael Neves <raneves.mg-Re5JQEeQqe8AvxtiuMwx3w< at >public.gmane.org> wrote:

Firebrind OCM

Rafael Neves — 2013-05-13T17:54:56

Hi guys,

I trying retrieve all data on my column family using 
method persistenceFactory.getColumns("Geral2", 
"b25b4b70-bbd2-11e2-8f3e-90b11cf59ca2",false, "dinName", "dinEnd"); 

this don't work when I have created my column family using follow method:  persistenceFactory.executeQuery(Integer.class, 
Query.get(createColumnFamily(
columnFamily("Geral2"),
    columnDefinitions(
        primaryKey("myKey", ColumnDataType.UUID),
        column("dinName", ColumnDataType.TEXT),
        column("dinEnd", ColumnDataType.TEXT)
    ),
    storageOptions(
        storageOption(StorageParameter.COMMENT, "comment"),
        storageOption(StorageParameter.READ_REPAIR_CHANCE, "1")
    )
)));

so, I create this index:
persistenceFactory.executeQuery(Integer.class, Query.get(createIndex(
onColumnFamily("Geral2"),
indexName("myIndex"),
column("dinName")
)));

but I have the follow error:
Exception in thread "main" 
me.prettyprint.hector.api.exceptions.HInvalidRequestException: 
InvalidRequestException(why:No indexed columns

Insert column DateType value

Alexandr S. — 2013-05-10T21:25:19

How to insert DateType value from Hector client in columnfamily? Is need 
any external  library?
Thanks

CQL 3 Inserting Data w/ Composite Keys

Paul Monday — 2013-05-10T18:52:20

I am trying to use CQL3 through the Hector API.  I've had some limited 
successes, but they are matched and exceeded by failures :(  Some successes 
include:  Insertion of data with UUID keys through the Mutator, limited 
query successes.

Right now I'm trying to insert to a CQL3 table with a composite key, am I 
pushing CQL3 through Hector too hard?  I'm using
   <dependency>
  <groupId>org.hectorclient</groupId>
  <artifactId>hector-core</artifactId>
  <version>1.1-3</version>
  </dependency>

Here is the table created in cqlsh -3
CREATE TABLE providers (providerid uuid, providername text, providertype 
text, active int, data text, primary key (providerid, providername, 
providertype, active)) WITH COMPACT STORAGE;

And here is an insert off the command line:
cqlsh:consumerinformation_3_0> insert into providers (providerid, 
providername, providertype, active, data) values 
(603db8fa-a2b7-4744-b568-11a2722f2042, 'M', 'Z', 0, 'data');
cqlsh:consumerinformation_3_0> select * from providers;

 providerid

Re: Fetching columns for a row preserving data types.

Ashu — 2013-05-09T07:31:05

Hi Vamshi

Can you paste your final code here? Actually I am facing same problem and the 
thing is I dont know the data type of column values in advance. So we have to 
dynamically find that out and then use frombytebuffer accordingle. Can you 
provide some help?

Re: Problem retrieving data while using ByteBufferSerializer

Ashu — 2013-05-09T07:26:59

Hi Soumik..
I am facing the same problem. Can you send me your complete code after 
solving the issue of random data types?

[ANNOUNCEMENT] Apache Gora 0.3 Released

lewismc — 2013-05-08T21:30:20

Good Afternoon Everyone,

The Apache Gora team are proud to announce the release of Gora 0.3.
The Apache Gora open source framework provides an in-memory data model and 
persistence for big data. Gora supports persisting to column stores, key 
value stores, document stores and RDBMSs, and analyzing the data with 
extensive Apache Hadoop™ MapReduce support. Gora uses the Apache Software 
License v2.0. 

Gora currently uses Hector Client as the underlying Cassandra client and we 
have been working to make sure that the gora-cassandra module was improved 
within this release.

This point release offers users significant improvements to a number of 
modules including a number of bug fixes, however of significant interest to 
the DynamoDB community will be the addition of a gora-dynamodb datastore 
for mapping and persisting objects to Amazon's DynamoDB [0]. Additionally 
the release includes various improvements to the gora-core module and a new 
Web Services API implementation which enables users to extend Go

Re: same code, differnet running time

月张 — 2013-05-07T02:48:14

what's related to that.

the cluster was idle and only running my code. 


在 2013年5月6日星期一UTC+8下午2时52分59秒，Sumit Thakur写道：