Apache Flink DataSet API: Wie füge ich ein Flink DataSet mit sich selbst zu einem neuen zusammen?

Question

Ich habe eine einzige Dimension DataSet vom Typ String:

DataSet<String> x = //['dog','cat','sheep'] 

Ich möchte alle Strings mit den anderen diesem Datensatz vergleichen verschiedene String-Ähnlichkeitsalgorithmen zu analysieren. Deshalb brauche ich eine resultierende Datensatz mit der folgenden Struktur:

DataSet<Tuple2<String,String>> y = //[{'dog','cat'},{'dog','sheep'},{'cat','sheep'}] 

Auf diesem Datensatz eine flatMap Funktion (oder ähnlich) angewandt werden, kann die Strings zu vergleichen.

Mein Problem ist, dass ich nicht weiß, welche Transformation ich verwenden muss. Vielleicht ist eine Transformation nicht der richtige Weg, damit umzugehen.

Im Klar Java I einfache Verwendung zwei Schleifen wie folgt aus:

for(int i = 0; i < x.length() ; i++){ 
    for(int j = i+1 ; i< x.length(); j++){ 
     //do something with x[i] and x[j] 
    } 
} 

Answer 1

x.cross (x) sollte es tun. Dies wird ein Standard-Kreuz ausführen.