Konvertieren Seq zu Rohr in verbrühen

Question

Kontext: Ich lese in einer Datei, wo mehrere Felder eine Liste von IDs sind. Ich muss diese Felder in eine Pipe konvertieren, um sie mit anderen Pipes zu verbinden.

Was habe ich versucht:

val otherPipe = pipe 
    .project('fieldIwant) 
    .map { p: Pipe => p.toString.split(",") } // converts pipe -> array 
    .unique 

Answer 1

Sie eine TypedPipe aus einer Sammlung bekommen mit:

TypedPipe.from(Seq(1, 2, 3, 4, 555, 3)) 

Wenn Sie zurück zu FieldsAPI fallen müssen (was veraltet ist), Sie kann es unter Verwendung

TypedPipe.from(Seq(1, 2, 3, 4, 555, 3)).toPipe('fieldName) 

tun