keys list from java client

2010-10-24 Thread Andrea Campolonghi
(); while(it.hasNext()){ key = (String) it.next(); if(filter.accept(key)){ if(remove(key)) counter++; } } } My issue is that I always get an emtpy list while I am sure keys exists in the bucket. Any suggestion? -- Andrea Campolonghi Cell : +39 347

is java client dead?

2010-10-25 Thread Andrea Campolonghi
Hi, I see that the tickets opened on the riak-java-client bitbucket site are considered since several monthes. Is that driver project still alive? If not does exists a different riak client for java? Thanks -- Andrea Campolonghi Cell : +39 347 2298435 and...@andreacfm.com http

doc about riak-java-pb-client

2010-10-29 Thread Andrea Campolonghi
Hi, does someone knows where I can find some docs about riak-java-pb-client. This really sounds like a nice project but I cannot find some docs to see if it does what I need. Andrea -- Andrea Campolonghi Cell : +39 347 2298435 and...@andreacfm.com http://www.andreacfm.com Railo Team and

listkeys

2010-10-29 Thread Andrea Campolonghi
: ByteString[] buckets = this.rc.listBuckets(); for(ByteString bucket : buckets){ KeySource keys = this.rc.listKeys(bucket); } but this is completely unuseful if I cannot say I want keys for THIS bucket etc... Any suggestion? -- Andrea Campolonghi Cell : +39 347 2298435 and...@andreacfm.com

fetch from java client

2010-11-01 Thread Andrea Campolonghi
= this.rc.fetch(this.bucket, key.toLowerCase()); I get an IOException. Am I making something wrong ?? Thanks Andrea p.s. Client is *riak-java-pb-client <http://github.com/krestenkrab/riak-java-pb-client>* -- Andrea Campolonghi Cell : +39 347 2298435 and...@andreacfm.com http://www.andreacfm.com

Overwrite from java client

2010-11-01 Thread Andrea Campolonghi
Riak-java-pb-client complains with an IOException if I try to store into riak a key that already exists. Does exists a way to trasparently say to overwrite a key/value. Now I have to check if key exists, delate and push. Any suggestion? Thanks -- Andrea Campolonghi Cell : +39 347 2298435 and

java client out of memory

2010-11-03 Thread Andrea Campolonghi
tion.receive(RiakConnection.java:89) at com.trifork.riak.RiakClient.store(RiakClient.java:384) at com.trifork.riak.RiakClient.store(RiakClient.java:363) at Runner.main(Runner.java:22) Any suggestion??? Andrea -- Andrea Campolonghi Cell : +39 347 2298435 and...@andreacfm.com http://www.andreacfm.

Re: java client out of memory

2010-11-03 Thread Andrea Campolonghi
lps, > > Andy > > On Wed, Nov 3, 2010 at 12:50 PM, Andrea Campolonghi < > acampolon...@gmail.com> wrote: > >> Hi, >> >> I am trying to use the riak-java-pb-client. >> Sample very very basic code >> >> public static void main(String[

mapreduce

2010-11-09 Thread Andrea Campolonghi
34,"hits":0,"lastModified":1289247328234,"exprires":1289247328234,"value":"'Susanne'","lifeSpan":0} Now When I try to run this from the riak console I do not get any result: {"input":"bucket","query&quo

Re: mapreduce

2010-11-09 Thread Andrea Campolonghi
o find a way to debug this. Any suggestion? Thanks Andrea 2010/11/9 Kevin Smith > That is the JSON format for a MapReduce job. You need to POST it to the > mapred end point like so: > > curl -XPOST -H"content-type=application/json" -d - > http://localhost:8098/ma

Re: several crashes on my dev machine

2010-11-15 Thread Andrea Campolonghi
eam]]}, {os,start_port_srv_loop,2}]} =INFO REPORT 15-Nov-2010::21:01:03 === application: os_mon exited: shutdown type: permanent {"Kernel pid terminated",application_controller,"{application_terminated,os_mon,shutdown}"} Crash dump was written to: erl_cra

riak hangs

2010-11-18 Thread Andrea Campolonghi
-Nov-2010::21:42:05 === {mochiweb_socket_server,256,{acceptor_error,{error,accept_failed}}} =ERROR REPORT 18-Nov-2010::21:42:05 === {mochiweb_socket_server,256,{acceptor_error,{error,accept_failed}}} =ERROR REPORT 18-Nov-2010::21:42:05 === {mochiweb_socket_server,256,{acceptor_error,{error

riak do not start

2010-11-19 Thread Andrea Campolonghi
{bitcask_merge_worker, do_merge, 1}]} Is this possible this to be related to ip settings in config file? Thanks -- Andrea Campolonghi Cell : +39 347 2298435 acampolon...@gmail.

java driver : lisKeys() returned also deleted keys

2010-11-20 Thread Andrea Campolonghi
while(keys.hasNext()){ String key = keys.next().toStringUtf8(); result.add(key); } }catch(IOException e){ e.printStackTrace(); } return result; } } -- Andrea Campolonghi Cell : +39 347 2298435 acampolon...@gmail.com and...@andreacfm.com http://www.andreacfm.com

Re: java driver : lisKeys() returned also deleted keys

2010-11-20 Thread Andrea Campolonghi
ert a sleep between the delete() and keys() calls (try a few seconds) - > does the test pass? > > - Andy > > > On Sat, Nov 20, 2010 at 10:02 AM, Andrea Campolonghi < > acampolon...@gmail.com> wrote: > >> I am having this issues with the java driver : >&g

Re: java driver : lisKeys() returned also deleted keys

2010-11-20 Thread Andrea Campolonghi
a tombstone marker and then reaped asynchronously. If you >> insert a sleep between the delete() and keys() calls (try a few seconds) - >> does the test pass? >> >> - Andy >> >> >> On Sat, Nov 20, 2010 at 10:02 AM, Andrea Campolonghi < >> acampolon