c1">// chain operations on dataStream of Row and sink the output</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w"></span><span class="c1">// end method chaining</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w"></span><span class="n">env</span><span class="p">.</span><span class="na">execute</span><span class="p">()</span><span class="w">
</sp