Re: PCollection to PCollection Conversion

2016-12-29 Thread Vikas Kedigehalli
>>>>>>>>> plus the difficulty of judging which transforms > go > > > > where, > > > > > > are > > > > > > > > >>>>> probably > > > > > > > > >>>>>>>>> why > > > > >

Re: PCollection to PCollection Conversion

2016-12-29 Thread Ben Chambers
>>>>> * at least they are separate classes and not methods > on > > > > > > >>> PCollection > > > > > > >>>>>>> :-) > > > > > > >>>>>>>>>>> > >

Re: PCollection to PCollection Conversion

2016-12-29 Thread Jesse Anderson
; Others? > > > > > > > >>>>>>>>>>> > > > > > > > >>>>>>>>>>> Kenn > > > > > > > >>>>>>>>>>> > > > > > > > >>>>>

Re: PCollection to PCollection Conversion

2016-12-29 Thread Jesse Anderson
dea of having a home > for > > > > those > > > > > >>>>>>>>>> transforms > > > > > >>>>>>>>>>>> that are not core enough to be part of the sdk, but > that > > > we > > > > >

Re: PCollection to PCollection Conversion

2016-12-29 Thread Ben Chambers
; > > > but > > > > >>>>> also > > > > >>>>>>> as > > > > >>>>>>>>>> a > > > > >>>>>>>>>>>> reference of good practices of Beam development, and for > > &

Re: PCollection to PCollection Conversion

2016-12-29 Thread Dan Halperin
>> DSL > > > >>>>>>>>>>> or > > > >>>>>>>>>>>> if those could be grouped with the current extensions > (e.g. > > > >> Join > > > >>>>> and > > > >>>>>>>>>>>> S

Re: PCollection to PCollection Conversion

2016-12-29 Thread Jesse Anderson
t;>>>>>> start working on something like this. > > >>>>>>>>>>>> > > >>>>>>>>>>>> Ismaël Mejía​ > > >>>>>>>>>>>> > > >>>>>>>>>>>> > > >>>

Re: PCollection to PCollection Conversion

2016-12-29 Thread Ben Chambers
> if those could be grouped with the current extensions > (e.g. > > > >> Join > > > >>>>> and > > > >>>>>>>>>>>> SortValues) into something more general that we as a >

Re: PCollection to PCollection Conversion

2016-12-29 Thread Dan Halperin
gt;>>> Ismaël Mejía​ > > >>>>>>>>>>>> > > >>>>>>>>>>>> > > >>>>>>>>>>>> On Wed, Nov 9, 2016 at 11:59 AM, Jean-Baptiste Onofré < > > >>>>>

Re: PCollection to PCollection Conversion

2016-12-29 Thread Jesse Anderson
;>>>>>>>> connectors/transforms for Spark and Flink. > >>>>>>>>>>>>> > >>>>>>>>>>>>> IMHO, right now, Beam should host this, not sure if it makes > >>> sense > >>

Re: PCollection to PCollection Conversion

2016-12-28 Thread Jean-Baptiste Onofré
tIO.Write so it seems logical that we would want to have a ParDo do the conversion. Text file formats have a lot of variance, even if you consider the subset of CSV like formats where it could have fixed width fields, or escaping and quoting around other fields, or he

Re: PCollection to PCollection Conversion

2016-12-28 Thread Vikas Kedigehalli
formations" package would serve both > users > > >>>> quick > > >>>>>>>>>>> ramp-up and ease-of-use while keeping Beam more "enabling" ? > > >>>>>>>>>>> > > >&