><span class="mi">0</span><span class="p">:</span> <span class="n">select_stream</span><span class="p">},</span>
        <span class="n">partitioners</span><span class="o">=</span><span class="p">{</span><span class="mi">0</span><span class="p">:</span> <span class="n">partitioner</span><span class="p">},</span>
        <span class="n">node</span><span class="o">=</span><span class="n">custom_node</span><span class="p">,</span>
        <span class="n">schema</span><span class="o">=</span><span class="n">new