def METHOD_NAME(descriptor):
    plan = DataQuantaBuilder(descriptor)
    dq_source_a = plan.source("../test/lines.txt")
    dq_source_b = plan.source("../test/morelines.txt")
    sink_dataquanta = dq_source_a.union(dq_source_b) \
        .sink("../test/output.txt", end="")
    return sink_dataquanta