Re: Write each group to its own file

2017-10-23 Thread Piotr Nowojski
You’re welcome :) > On 23 Oct 2017, at 20:43, Rodrigo Lazoti wrote: > > Piotr, > > I did as you suggested and it worked perfectly. > Thank you! :) > > Best, > Rodrigo > > On Thu, Oct 12, 2017 at 5:11 AM, Piotr Nowojski > wrote: > Hi, > > There is no straightf

Re: Write each group to its own file

2017-10-23 Thread Rodrigo Lazoti
Piotr, I did as you suggested and it worked perfectly. Thank you! :) Best, Rodrigo On Thu, Oct 12, 2017 at 5:11 AM, Piotr Nowojski wrote: > Hi, > > There is no straightforward way to do that. First of all, the error you > are getting is because you are trying to start new application ( > env.f

Re: Write each group to its own file

2017-10-12 Thread Piotr Nowojski
Hi, There is no straightforward way to do that. First of all, the error you are getting is because you are trying to start new application ( env.fromElements(items) ) inside your reduce function. To do what you want, you have to hash partition the products based on category (instead of groupin