Google Git
Sign in
apache/iotdb-website/refs/heads/asf-staging/./assets/Flink-TsFile.html-Rlhulffp.js
blob: 1680e3eb53f5d67deae58932e61579ea0b05352e [file]
import{_ as n,c as a,b as l,o as p}from"./app-C1IcKGP3.js";const o={};function e(t,s){return p(),a("div",null,[...s[0]||(s[0]=[l(`<h2 id="tsfile-flink-连接器" tabindex="-1"><a class="header-anchor" href="#tsfile-flink-连接器"><span>TsFile-Flink 连接器</span></a></h2><h3 id="关于-tsfile-flink-连接器" tabindex="-1"><a class="header-anchor" href="#关于-tsfile-flink-连接器"><span>关于 TsFile-Flink 连接器</span></a></h3><p>TsFile-Flink-Connector 对 Tsfile 类型的外部数据源实现 Flink 的支持。 这使用户可以通过 Flink DataStream/DataSet 进行读取，写入和查询。</p><p>使用此连接器，您可以</p><ul><li>从本地文件系统或 hdfs 加载单个或多个 TsFile （只支持以 DataSet 的形式）到 Flink 。</li><li>将本地文件系统或 hdfs 中特定目录中的所有文件加载到 Flink 中。</li></ul><h3 id="快速开始" tabindex="-1"><a class="header-anchor" href="#快速开始"><span>快速开始</span></a></h3><h4 id="tsfileinputformat-示例" tabindex="-1"><a class="header-anchor" href="#tsfileinputformat-示例"><span>TsFileInputFormat 示例</span></a></h4><ol><li>使用默认的 RowRowRecordParser 创建 TsFileInputFormat 。</li></ol><div class="language-java line-numbers-mode" data-highlighter="shiki" data-ext="java" style="background-color:#282c34;color:#abb2bf;"><pre class="shiki one-dark-pro vp-code"><code class="language-java"><span class="line"><span style="color:#E5C07B;">String</span><span style="color:#E06C75;">[] filedNames </span><span style="color:#56B6C2;">=</span><span style="color:#E06C75;"> {</span></span>
<span class="line"><span style="color:#E5C07B;"> QueryConstant</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">RESERVED_TIME</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_1.sensor_1&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_1.sensor_2&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_1.sensor_3&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_2.sensor_1&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_2.sensor_2&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_2.sensor_3&quot;</span></span>
<span class="line"><span style="color:#E06C75;">}</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">TypeInformation</span><span style="color:#E06C75;">[] typeInformations </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#E5C07B;"> TypeInformation</span><span style="color:#E06C75;">[] {</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">FLOAT</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">INT</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">INT</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">FLOAT</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">INT</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">INT</span></span>
<span class="line"><span style="color:#E06C75;">}</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">List</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">Path</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> paths </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> Arrays</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">stream</span><span style="color:#ABB2BF;">(filedNames)</span></span>
<span class="line"><span style="color:#ABB2BF;"> .</span><span style="color:#61AFEF;">filter</span><span style="color:#ABB2BF;">(s </span><span style="color:#C678DD;">-&gt;</span><span style="color:#56B6C2;"> !</span><span style="color:#E5C07B;">s</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">equals</span><span style="color:#ABB2BF;">(</span><span style="color:#E5C07B;">QueryConstant</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">RESERVED_TIME</span><span style="color:#ABB2BF;">))</span></span>
<span class="line"><span style="color:#ABB2BF;"> .</span><span style="color:#61AFEF;">map</span><span style="color:#ABB2BF;">(Path</span><span style="color:#C678DD;">::new</span><span style="color:#ABB2BF;">)</span></span>
<span class="line"><span style="color:#ABB2BF;"> .</span><span style="color:#61AFEF;">collect</span><span style="color:#ABB2BF;">(</span><span style="color:#E5C07B;">Collectors</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">toList</span><span style="color:#ABB2BF;">());</span></span>
<span class="line"><span style="color:#E5C07B;">RowTypeInfo</span><span style="color:#E06C75;"> rowTypeInfo </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#61AFEF;"> RowTypeInfo</span><span style="color:#E06C75;">(typeInformations</span><span style="color:#ABB2BF;">,</span><span style="color:#E06C75;"> filedNames)</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">QueryExpression</span><span style="color:#E06C75;"> queryExpression </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> QueryExpression</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">create</span><span style="color:#ABB2BF;">(paths, </span><span style="color:#D19A66;">null</span><span style="color:#ABB2BF;">);</span></span>
<span class="line"><span style="color:#E5C07B;">RowRowRecordParser</span><span style="color:#E06C75;"> parser </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> RowRowRecordParser</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">create</span><span style="color:#ABB2BF;">(rowTypeInfo, </span><span style="color:#E5C07B;">queryExpression</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">getSelectedSeries</span><span style="color:#ABB2BF;">());</span></span>
<span class="line"><span style="color:#E5C07B;">TsFileInputFormat</span><span style="color:#E06C75;"> inputFormat </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#E5C07B;"> TsFileInputFormat</span><span style="color:#ABB2BF;">&lt;&gt;</span><span style="color:#E06C75;">(queryExpression</span><span style="color:#ABB2BF;">,</span><span style="color:#E06C75;"> parser)</span><span style="color:#ABB2BF;">;</span></span></code></pre><div class="line-numbers" aria-hidden="true" style="counter-reset:line-number 0;"><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div></div></div><ol start="2"><li>从输入格式读取数据并打印到标准输出 stdout：</li></ol><p>DataStream：</p><div class="language-java line-numbers-mode" data-highlighter="shiki" data-ext="java" style="background-color:#282c34;color:#abb2bf;"><pre class="shiki one-dark-pro vp-code"><code class="language-java"><span class="line"><span style="color:#E5C07B;">StreamExecutionEnvironment</span><span style="color:#E06C75;"> senv </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> StreamExecutionEnvironment</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">getExecutionEnvironment</span><span style="color:#ABB2BF;">();</span></span>
<span class="line"><span style="color:#E5C07B;">inputFormat</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">setFilePath</span><span style="color:#ABB2BF;">(</span><span style="color:#98C379;">&quot;source.tsfile&quot;</span><span style="color:#ABB2BF;">);</span></span>
<span class="line"><span style="color:#E5C07B;">DataStream</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">Row</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> source </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> senv</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">createInput</span><span style="color:#ABB2BF;">(inputFormat);</span></span>
<span class="line"><span style="color:#E5C07B;">DataStream</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">String</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> rowString </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> source</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">map</span><span style="color:#ABB2BF;">(Row</span><span style="color:#C678DD;">::</span><span style="color:#ABB2BF;">toString);</span></span>
<span class="line"><span style="color:#E5C07B;">Iterator</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">String</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> result </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> DataStreamUtils</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">collect</span><span style="color:#ABB2BF;">(rowString);</span></span>
<span class="line"><span style="color:#C678DD;">while</span><span style="color:#E06C75;"> (</span><span style="color:#E5C07B;">result</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">hasNext</span><span style="color:#ABB2BF;">()</span><span style="color:#E06C75;">) {</span></span>
<span class="line"><span style="color:#E5C07B;"> System</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">out</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">println</span><span style="color:#ABB2BF;">(</span><span style="color:#E5C07B;">result</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">next</span><span style="color:#ABB2BF;">());</span></span>
<span class="line"><span style="color:#E06C75;">}</span></span></code></pre><div class="line-numbers" aria-hidden="true" style="counter-reset:line-number 0;"><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div></div></div><p>DataSet：</p><div class="language-java line-numbers-mode" data-highlighter="shiki" data-ext="java" style="background-color:#282c34;color:#abb2bf;"><pre class="shiki one-dark-pro vp-code"><code class="language-java"><span class="line"><span style="color:#E5C07B;">ExecutionEnvironment</span><span style="color:#E06C75;"> env </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> ExecutionEnvironment</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">getExecutionEnvironment</span><span style="color:#ABB2BF;">();</span></span>
<span class="line"><span style="color:#E5C07B;">inputFormat</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">setFilePath</span><span style="color:#ABB2BF;">(</span><span style="color:#98C379;">&quot;source.tsfile&quot;</span><span style="color:#ABB2BF;">);</span></span>
<span class="line"><span style="color:#E5C07B;">DataSet</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">Row</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> source </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> env</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">createInput</span><span style="color:#ABB2BF;">(inputFormat);</span></span>
<span class="line"><span style="color:#E5C07B;">List</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">String</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> result </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> source</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">map</span><span style="color:#ABB2BF;">(Row</span><span style="color:#C678DD;">::</span><span style="color:#ABB2BF;">toString).</span><span style="color:#61AFEF;">collect</span><span style="color:#ABB2BF;">();</span></span>
<span class="line"><span style="color:#C678DD;">for</span><span style="color:#E06C75;"> (</span><span style="color:#E5C07B;">String</span><span style="color:#E06C75;"> s </span><span style="color:#C678DD;">:</span><span style="color:#E06C75;"> result) {</span></span>
<span class="line"><span style="color:#E5C07B;"> System</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">out</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">println</span><span style="color:#ABB2BF;">(s);</span></span>
<span class="line"><span style="color:#E06C75;">}</span></span></code></pre><div class="line-numbers" aria-hidden="true" style="counter-reset:line-number 0;"><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div></div></div><h4 id="tsrecordoutputformat-示例" tabindex="-1"><a class="header-anchor" href="#tsrecordoutputformat-示例"><span>TSRecordOutputFormat 示例</span></a></h4><ol><li>使用默认的 RowTSRecordConverter 创建 TSRecordOutputFormat 。</li></ol><div class="language-java line-numbers-mode" data-highlighter="shiki" data-ext="java" style="background-color:#282c34;color:#abb2bf;"><pre class="shiki one-dark-pro vp-code"><code class="language-java"><span class="line"><span style="color:#E5C07B;">String</span><span style="color:#E06C75;">[] filedNames </span><span style="color:#56B6C2;">=</span><span style="color:#E06C75;"> {</span></span>
<span class="line"><span style="color:#E5C07B;"> QueryConstant</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">RESERVED_TIME</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_1.sensor_1&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_1.sensor_2&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_1.sensor_3&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_2.sensor_1&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_2.sensor_2&quot;</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#98C379;"> &quot;device_2.sensor_3&quot;</span></span>
<span class="line"><span style="color:#E06C75;">}</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">TypeInformation</span><span style="color:#E06C75;">[] typeInformations </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#E5C07B;"> TypeInformation</span><span style="color:#E06C75;">[] {</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">,</span></span>
<span class="line"><span style="color:#E5C07B;"> Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span></span>
<span class="line"><span style="color:#E06C75;">}</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">RowTypeInfo</span><span style="color:#E06C75;"> rowTypeInfo </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#61AFEF;"> RowTypeInfo</span><span style="color:#E06C75;">(typeInformations</span><span style="color:#ABB2BF;">,</span><span style="color:#E06C75;"> filedNames)</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">Schema</span><span style="color:#E06C75;"> schema </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#61AFEF;"> Schema</span><span style="color:#E06C75;">()</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">schema</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">extendTemplate</span><span style="color:#ABB2BF;">(</span><span style="color:#98C379;">&quot;template&quot;</span><span style="color:#ABB2BF;">, </span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> MeasurementSchema</span><span style="color:#ABB2BF;">(</span><span style="color:#98C379;">&quot;sensor_1&quot;</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">TSDataType</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">INT64</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">TSEncoding</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">TS_2DIFF</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">schema</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">extendTemplate</span><span style="color:#ABB2BF;">(</span><span style="color:#98C379;">&quot;template&quot;</span><span style="color:#ABB2BF;">, </span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> MeasurementSchema</span><span style="color:#ABB2BF;">(</span><span style="color:#98C379;">&quot;sensor_2&quot;</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">TSDataType</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">INT64</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">TSEncoding</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">TS_2DIFF</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">schema</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">extendTemplate</span><span style="color:#ABB2BF;">(</span><span style="color:#98C379;">&quot;template&quot;</span><span style="color:#ABB2BF;">, </span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> MeasurementSchema</span><span style="color:#ABB2BF;">(</span><span style="color:#98C379;">&quot;sensor_3&quot;</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">TSDataType</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">INT64</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">TSEncoding</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">TS_2DIFF</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">RowTSRecordConverter</span><span style="color:#E06C75;"> converter </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#61AFEF;"> RowTSRecordConverter</span><span style="color:#E06C75;">(rowTypeInfo)</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">TSRecordOutputFormat</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">Row</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> outputFormat </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#E5C07B;"> TSRecordOutputFormat</span><span style="color:#ABB2BF;">&lt;&gt;</span><span style="color:#E06C75;">(schema</span><span style="color:#ABB2BF;">,</span><span style="color:#E06C75;"> converter)</span><span style="color:#ABB2BF;">;</span></span></code></pre><div class="line-numbers" aria-hidden="true" style="counter-reset:line-number 0;"><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div></div></div><ol start="2"><li>通过输出格式写数据：</li></ol><p>DataStream:</p><div class="language-java line-numbers-mode" data-highlighter="shiki" data-ext="java" style="background-color:#282c34;color:#abb2bf;"><pre class="shiki one-dark-pro vp-code"><code class="language-java"><span class="line"><span style="color:#E5C07B;">StreamExecutionEnvironment</span><span style="color:#E06C75;"> senv </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> StreamExecutionEnvironment</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">getExecutionEnvironment</span><span style="color:#ABB2BF;">();</span></span>
<span class="line"><span style="color:#E5C07B;">senv</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">setParallelism</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">1</span><span style="color:#ABB2BF;">);</span></span>
<span class="line"><span style="color:#E5C07B;">List</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">Tuple7</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> data </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#E5C07B;"> ArrayList</span><span style="color:#ABB2BF;">&lt;&gt;</span><span style="color:#E06C75;">(</span><span style="color:#D19A66;">7</span><span style="color:#E06C75;">)</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">1L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">2L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">3L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">4L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">5L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">2L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">3L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">4L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">5L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">3L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">4L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">5L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">4L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">5L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">10L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">10L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">11L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">10L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">11L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">12L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">10L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">11L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">12L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">13L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">outputFormat</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">setOutputFilePath</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#ABB2BF;"> org.</span><span style="color:#E5C07B;">apache</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">flink</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">core</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">fs</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">Path</span><span style="color:#ABB2BF;">(path));</span></span>
<span class="line"><span style="color:#E5C07B;">DataStream</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">Tuple7</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> source </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> senv</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">fromCollection</span><span style="color:#ABB2BF;">(</span></span>
<span class="line"><span style="color:#ABB2BF;"> data, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">TUPLE</span><span style="color:#ABB2BF;">(</span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">source</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">map</span><span style="color:#ABB2BF;">(t </span><span style="color:#C678DD;">-&gt;</span><span style="color:#ABB2BF;"> {</span></span>
<span class="line"><span style="color:#E5C07B;"> Row</span><span style="color:#E06C75;"> row</span><span style="color:#56B6C2;"> =</span><span style="color:#C678DD;"> new</span><span style="color:#61AFEF;"> Row</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">7</span><span style="color:#ABB2BF;">);</span></span>
<span class="line"><span style="color:#C678DD;"> for</span><span style="color:#ABB2BF;"> (</span><span style="color:#C678DD;">int</span><span style="color:#E06C75;"> i</span><span style="color:#56B6C2;"> =</span><span style="color:#D19A66;"> 0</span><span style="color:#ABB2BF;">; i </span><span style="color:#56B6C2;">&lt;</span><span style="color:#D19A66;"> 7</span><span style="color:#ABB2BF;">; i++) {</span></span>
<span class="line"><span style="color:#E5C07B;"> row</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">setField</span><span style="color:#ABB2BF;">(i, </span><span style="color:#E5C07B;">t</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">getField</span><span style="color:#ABB2BF;">(i));</span></span>
<span class="line"><span style="color:#ABB2BF;"> }</span></span>
<span class="line"><span style="color:#C678DD;"> return</span><span style="color:#ABB2BF;"> row;</span></span>
<span class="line"><span style="color:#ABB2BF;">}).</span><span style="color:#61AFEF;">returns</span><span style="color:#ABB2BF;">(rowTypeInfo).</span><span style="color:#61AFEF;">writeUsingOutputFormat</span><span style="color:#ABB2BF;">(outputFormat);</span></span>
<span class="line"><span style="color:#E5C07B;">senv</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">execute</span><span style="color:#ABB2BF;">();</span></span></code></pre><div class="line-numbers" aria-hidden="true" style="counter-reset:line-number 0;"><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div></div></div><p>DataSet:</p><div class="language-java line-numbers-mode" data-highlighter="shiki" data-ext="java" style="background-color:#282c34;color:#abb2bf;"><pre class="shiki one-dark-pro vp-code"><code class="language-java"><span class="line"><span style="color:#E5C07B;">ExecutionEnvironment</span><span style="color:#E06C75;"> env </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> ExecutionEnvironment</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">getExecutionEnvironment</span><span style="color:#ABB2BF;">();</span></span>
<span class="line"><span style="color:#E5C07B;">env</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">setParallelism</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">1</span><span style="color:#ABB2BF;">);</span></span>
<span class="line"><span style="color:#E5C07B;">List</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">Tuple7</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> data </span><span style="color:#56B6C2;">=</span><span style="color:#C678DD;"> new</span><span style="color:#E5C07B;"> ArrayList</span><span style="color:#ABB2BF;">&lt;&gt;</span><span style="color:#E06C75;">(</span><span style="color:#D19A66;">7</span><span style="color:#E06C75;">)</span><span style="color:#ABB2BF;">;</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">1L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">2L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">3L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">4L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">5L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">2L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">3L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">4L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">5L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">3L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">4L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">5L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">4L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">5L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">10L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">6L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">10L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">11L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">7L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">10L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">11L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">12L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">data</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">add</span><span style="color:#ABB2BF;">(</span><span style="color:#C678DD;">new</span><span style="color:#61AFEF;"> Tuple7</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">8L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">9L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">10L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">11L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">12L</span><span style="color:#ABB2BF;">, </span><span style="color:#D19A66;">13L</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">DataSet</span><span style="color:#ABB2BF;">&lt;</span><span style="color:#E5C07B;">Tuple7</span><span style="color:#ABB2BF;">&gt;</span><span style="color:#E06C75;"> source </span><span style="color:#56B6C2;">=</span><span style="color:#E5C07B;"> env</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">fromCollection</span><span style="color:#ABB2BF;">(</span></span>
<span class="line"><span style="color:#ABB2BF;"> data, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">TUPLE</span><span style="color:#ABB2BF;">(</span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">, </span><span style="color:#E5C07B;">Types</span><span style="color:#ABB2BF;">.</span><span style="color:#E5C07B;">LONG</span><span style="color:#ABB2BF;">));</span></span>
<span class="line"><span style="color:#E5C07B;">source</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">map</span><span style="color:#ABB2BF;">(t </span><span style="color:#C678DD;">-&gt;</span><span style="color:#ABB2BF;"> {</span></span>
<span class="line"><span style="color:#E5C07B;"> Row</span><span style="color:#E06C75;"> row</span><span style="color:#56B6C2;"> =</span><span style="color:#C678DD;"> new</span><span style="color:#61AFEF;"> Row</span><span style="color:#ABB2BF;">(</span><span style="color:#D19A66;">7</span><span style="color:#ABB2BF;">);</span></span>
<span class="line"><span style="color:#C678DD;"> for</span><span style="color:#ABB2BF;"> (</span><span style="color:#C678DD;">int</span><span style="color:#E06C75;"> i</span><span style="color:#56B6C2;"> =</span><span style="color:#D19A66;"> 0</span><span style="color:#ABB2BF;">; i </span><span style="color:#56B6C2;">&lt;</span><span style="color:#D19A66;"> 7</span><span style="color:#ABB2BF;">; i++) {</span></span>
<span class="line"><span style="color:#E5C07B;"> row</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">setField</span><span style="color:#ABB2BF;">(i, </span><span style="color:#E5C07B;">t</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">getField</span><span style="color:#ABB2BF;">(i));</span></span>
<span class="line"><span style="color:#ABB2BF;"> }</span></span>
<span class="line"><span style="color:#C678DD;"> return</span><span style="color:#ABB2BF;"> row;</span></span>
<span class="line"><span style="color:#ABB2BF;">}).</span><span style="color:#61AFEF;">returns</span><span style="color:#ABB2BF;">(rowTypeInfo).</span><span style="color:#61AFEF;">write</span><span style="color:#ABB2BF;">(outputFormat, path);</span></span>
<span class="line"><span style="color:#E5C07B;">env</span><span style="color:#ABB2BF;">.</span><span style="color:#61AFEF;">execute</span><span style="color:#ABB2BF;">();</span></span></code></pre><div class="line-numbers" aria-hidden="true" style="counter-reset:line-number 0;"><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div><div class="line-number"></div></div></div>`,22)])])}const r=n(o,[["render",e]]),c=JSON.parse('{"path":"/zh/UserGuide/V0.13.x/Ecosystem-Integration/Flink-TsFile.html","title":"","lang":"zh-CN","frontmatter":{"description":"TsFile-Flink 连接器 关于 TsFile-Flink 连接器 TsFile-Flink-Connector 对 Tsfile 类型的外部数据源实现 Flink 的支持。 这使用户可以通过 Flink DataStream/DataSet 进行读取，写入和查询。 使用此连接器，您可以 从本地文件系统或 hdfs 加载单个或多个 TsFile ...","head":[["script",{"type":"application/ld+json"},"{\\"@context\\":\\"https://schema.org\\",\\"@type\\":\\"Article\\",\\"headline\\":\\"\\",\\"image\\":[\\"\\"],\\"dateModified\\":\\"2026-01-12T10:25:39.000Z\\",\\"author\\":[]}"],["meta",{"property":"og:url","content":"https://iotdb.apache.org/zh/UserGuide/V0.13.x/Ecosystem-Integration/Flink-TsFile.html"}],["meta",{"property":"og:site_name","content":"IoTDB Website"}],["meta",{"property":"og:description","content":"TsFile-Flink 连接器 关于 TsFile-Flink 连接器 TsFile-Flink-Connector 对 Tsfile 类型的外部数据源实现 Flink 的支持。 这使用户可以通过 Flink DataStream/DataSet 进行读取，写入和查询。 使用此连接器，您可以 从本地文件系统或 hdfs 加载单个或多个 TsFile ..."}],["meta",{"property":"og:type","content":"article"}],["meta",{"property":"og:locale","content":"zh-CN"}],["meta",{"property":"og:locale:alternate","content":"en-US"}],["meta",{"property":"og:updated_time","content":"2026-01-12T10:25:39.000Z"}],["meta",{"property":"article:modified_time","content":"2026-01-12T10:25:39.000Z"}],["link",{"rel":"alternate","hreflang":"en-us","href":"https://iotdb.apache.org/UserGuide/V0.13.x/Ecosystem-Integration/Flink-TsFile.html"}]]},"git":{"createdTime":1768213539000,"updatedTime":1768213539000,"contributors":[{"name":"CritasWang","username":"CritasWang","email":"critas@outlook.com","commits":1,"url":"https://github.com/CritasWang"}]},"readingTime":{"minutes":2.35,"words":704},"filePathRelative":"zh/UserGuide/V0.13.x/Ecosystem-Integration/Flink-TsFile.md","autoDesc":true}');export{r as comp,c as data};