대신 나는이처럼 보이는 끓는 작업이

Question

튜플의 목록으로 튜플을 방출하는 방법 :.

수입 com.twitter.scalding을 {인수, CSV, 작업, TextLine입니다}

class DataJob(args: Args) extends Job(args) { 

    val input = args("input") 
    val output = Csv(args("output"), separator = ",") 

    def parseLine(x: String):Seq[(String, String, String, String)] = { 
    List(("a", "b", "c", "d")) //Returns a list, not a tuple 
    } 

    TextLine(input).mapTo('line -> ('v1, 'v2, 'v3, 'v4)) { 
    x:String => { 
    parseLine(x) // this code fails with arity error 
    } 
    }.write(Csv(args("output"))) 
} 

이 실행되면, 나는 다음과 같은 오류가 발생합니다 : 내 parseLine 기능은 튜플의리스트를 반환하지만 코드가 하나의 튜플이 방출 될 것으로 예상하기 때문에

Caused by: java.lang.AssertionError: assertion failed: Arity of (class com.twitter.scalding.LowPriorityTupleSetters$$anon$2) is 1, which doesn't match: + ('v1', 'v2', 'v3', 'v4') 

이입니다. 이 코드를 어떻게 작동시킬 수 있습니까? 난 그냥 변경하는 데 필요한 같은

Answer 1

좋아 보인다 :

TextLine(input).mapTo('line -> ('v1, 'v2, 'v3, 'v4))

에 :

TextLine(input).flatMap('line -> ('v1, 'v2, 'v3, 'v4))

아직 정확하게 명확하지 왜 그렇게 어떤 응답 주시면 감사하겠습니다!