Re: Java MR

I know what makes a difference in groovy with anotation @groovy.transform.CompileStatic everything works as in java but why? and why this is a problem with java client 2.0 only - no idea? -- View this message in context: http://riak-users.197444.n3.nabble.com/Java-MR-tp4032117p4032228.html

Re: Java MR

I have got no clue why in Groove it does not work. But in meantime (in Java) I've got another problem - when running I want to achieve HTTP equivalent curl -s -X POST -H "Content-Type: application/json" http://localhost:8098/mapred -d '{"inputs":{"bucket":["bucket_type","bucket"],"index":"$key",

Re: Java MR

So I've verified that simple code in Java(1.7) is working fine, but in Groovy (2.3.6) it is not. And problem is only in Java Client 2.0. Working with 1.4 is doing fine in Groovy and Java as well. Everything is run from Intelij (does not know if matters). I am astonished. Till now I've tested only o

Re: Java MR

this example does not work because I have disabled phase to output, but I have changed this many times and I will find another example which does not work, but tomorrow now thank Chirs for help -- View this message in context: http://riak-users.197444.n3.nabble.com/Java-MR-tp4032117p4032215.h

Re: Java MR

Verified in Java - full code below - does not work - entry/key is in Riak - and curl -s -X POST -H "Content-Type: application/json" http://localhost:8098/mapred -d '{"inputs":{"bucket":"bucket2","key_filters":[["starts_with", "key"]]}, "query":[{"map":{"language":"javascript", "source":"function(v

Re: Java MR

> On Dec 3, 2014, at 1:24 PM, niedomnie wrote: > > Always Groovy. Not tried with java. But client 1.4 is working. And I've never > heard that Groovy could possibly interfere. > I will check it with plain java but do not expect much. > If you could sent a failing vanilla Java MR job, that woul

Re: Java MR

Always Groovy. Not tried with java. But client 1.4 is working. And I've never heard that Groovy could possibly interfere. I will check it with plain java but do not expect much. -- View this message in context: http://riak-users.197444.n3.nabble.com/Java-MR-tp4032117p4032212.html Sent from the

Re: Java MR

> On Dec 3, 2014, at 1:15 PM, niedomnie wrote: > > Before you comment that data is not stored in DB - check it first. It is. > And HTTP map reduce gives results. So this is false trace. > Data is in data base, client 1.4 is able to run MR job and fetch that data > (written to default bucket type)

Re: Java MR

And I've verified this example without futures (with execute() function) - does not working as well. -- View this message in context: http://riak-users.197444.n3.nabble.com/Java-MR-tp4032117p4032210.html Sent from the Riak Users mailing list archive at Nabble.com. _

Re: Java MR

Before you comment that data is not stored in DB - check it first. It is. And HTTP map reduce gives results. So this is false trace. Data is in data base, client 1.4 is able to run MR job and fetch that data (written to default bucket type), HTTP client used by curl is running job & fetching data.

Re: Java MR

> On Dec 3, 2014, at 1:04 PM, niedomnie wrote: > > no results (prints 0) on below code (using 2.0 java client from maven, and > connecting to riak 2.0), > I've changed map/reduce functions JS or Erlang, used different MapReduce > classes (for Bucket, BucketKey, or Index one) but without any luck

Re: Java MR

no results (prints 0) on below code (using 2.0 java client from maven, and connecting to riak 2.0), I've changed map/reduce functions JS or Erlang, used different MapReduce classes (for Bucket, BucketKey, or Index one) but without any luck. It is written in groovy - but I do not think that it diffe

Re: Java MR

> > On Dec 3, 2014, at 12:38 PM, niedomnie wrote: > > I know somethink - there are some examples of MR in java client 2.0 - which > does not work on my machine. > Although MR by HTTP is working fine. Can you provide the example of the jobs which are failing as well as the output? Thanks, Chris

Re: Java MR

I know somethink - there are some examples of MR in java client 2.0 - which does not work on my machine. Although MR by HTTP is working fine. -- View this message in context: http://riak-users.197444.n3.nabble.com/Java-MR-tp4032117p4032205.html Sent from the Riak Users mailing list archive at

Re: Java MR

I've ask then. We've got 4 MR jobs MapReduce mr = new BucketMapReduce.Builder().withMapPhase(Function.newNamedJsFunction("Riak.mapValues")); MapReduce mr = new SearchMapReduce.Builder().withIndex("\$key").withQuery(q).withMapPhase(Function.newNamedJsFunction("Riak.mapValues")); MapReduce mr = n

Re: Java MR

Hi Mohan, Can you describe what are you looking for more specifically? I’m having trouble making the connection between matrix multiplication and what you are actually want to store inside of Riak? Thanks, - Chris Christopher Meiklejohn Senior Software Engineer Basho Technologies, Inc. cmeikl