pyspark.ml import Pipeline</span>
<span class="sd">    &gt;&gt;&gt; documentAssembler = DocumentAssembler() \\</span>
<span class="sd">    ...     .setInputCol(&quot;text&quot;) \\</span>
<span class="sd">    ...     .setOutputCol(&quot;documents&quot;)</span>
<span class="sd">    &gt;&gt;&gt; t5 = T5Transformer.pretrained(&quot;t5_small&quot;) \\</span>
<span class="sd">    ...     .setTask(&quot;summarize:&quot;) \\</span>
<span class="sd">    ...     .setInputCols([&quot;documents&quot;]) \\</span>
<span