Apache Flink 0.9 ALS API

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Apache Flink 0.9 ALS API

Ronny Bräunlich
Hello everybody,

for a university project we use the current implementation of ALS in Flink 0.9 and we were wondering about the API of predict() and fit() requiring a DataSet[(Int, Int)] or DataSet[(Int, Int, Double]) respectively, because the range of Int is quite limited.
That is why we wanted to ask you if it wouldn’t be advantageous to change Int to Long, to allow more values.
Please let me know what you think about it.

Cheers,
Ronny
Reply | Threaded
Open this post in threaded view
|

Re: Apache Flink 0.9 ALS API

Robert Metzger
Hi Ronny,

I accepted your previous mail to the mailing list, you got two replies:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Apache-Flink-0-9-ALS-API-td6424.html

Sorry for the confusion.

On Sun, Jun 14, 2015 at 9:23 AM, Ronny Bräunlich <[hidden email]>
wrote:

> Hello everybody,
>
> for a university project we use the current implementation of ALS in Flink
> 0.9 and we were wondering about the API of predict() and fit() requiring a
> DataSet[(Int, Int)] or DataSet[(Int, Int, Double]) respectively, because
> the range of Int is quite limited.
> That is why we wanted to ask you if it wouldn’t be advantageous to change
> Int to Long, to allow more values.
> Please let me know what you think about it.
>
> Cheers,
> Ronny
Reply | Threaded
Open this post in threaded view
|

Re: Apache Flink 0.9 ALS API

Till Rohrmann
+1 for using long for both IDs.

But I don't understand what's the advantage of using a String as user ID.

On Sun, Jun 14, 2015 at 6:43 PM Robert Metzger <[hidden email]> wrote:

> Hi Ronny,
>
> I accepted your previous mail to the mailing list, you got two replies:
>
> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Apache-Flink-0-9-ALS-API-td6424.html
>
> Sorry for the confusion.
>
> On Sun, Jun 14, 2015 at 9:23 AM, Ronny Bräunlich <[hidden email]>
> wrote:
>
> > Hello everybody,
> >
> > for a university project we use the current implementation of ALS in
> Flink
> > 0.9 and we were wondering about the API of predict() and fit() requiring
> a
> > DataSet[(Int, Int)] or DataSet[(Int, Int, Double]) respectively, because
> > the range of Int is quite limited.
> > That is why we wanted to ask you if it wouldn’t be advantageous to change
> > Int to Long, to allow more values.
> > Please let me know what you think about it.
> >
> > Cheers,
> > Ronny
>