Index conversion

[Kürşat Kurt <ku...@kursatkurt.com>]

Hi;

 

I have label index DataSet and final DataSet that i want to convert its
indexes to labels.

 

ixDS: DataSet[(Long, String)]

(1,Car)

(2,Sports)

(3,Home)

...

 

finalDS:DataSet[(Long, String, Double, String, Double)]

(1,x,1,y,4)

(2,z,3,t,5)

...

 

If i want to convert finalDS's indexes with join like this:

 

val res=finalDS.join(ixDS).where(0).equalTo(0){(l,r)=> {

        (r._2,l._2)

        }} 

res.print();

 

I can not get labed indexes. 

If i collect and try to match each DS i could get labels :

 

finalDS.collect().foreach(x=>{

        ixDS.collect().foreach(y=> {

          if (x._1==y._1) System.err.println(">>>>>>>>"+x._2+","+y._2)

        })

      })

 

.. but i think it is the wrong way.

What is the correct way for conversion?