Skip to content

Commit fe07705

Browse files
zlzhang0122zlzhang0122
committed
first over
1 parent e89bc66 commit fe07705

14 files changed

+49
-58
lines changed

‎docs/_build/doctrees/environment.pickle

-112 Bytes
Binary file not shown.

‎docs/_build/doctrees/example.doctree

1.67 KB
Binary file not shown.

‎docs/_build/doctrees/index.doctree

-1.58 KB
Binary file not shown.

‎docs/_build/doctrees/jobSubmit.doctree

902 Bytes
Binary file not shown.

‎docs/_build/html/_sources/example.rst.txt

+8-1
Original file line numberDiff line numberDiff line change
@@ -22,4 +22,11 @@ Inline Markup
2222
-------------
2323
Words can have *emphasis in italics* or be **bold** and you can define
2424
code samples with back quotes, like when you talk about a command: ``sudo``
25-
gives you super user powers!
25+
gives you super user powers!
26+
27+
Indices and tables
28+
==================
29+
30+
* :ref:`genindex`
31+
* :ref:`modindex`
32+
* :ref:`search`

‎docs/_build/html/_sources/index.rst.txt

-7
Original file line numberDiff line numberDiff line change
@@ -11,10 +11,3 @@ Flink源码阅读文档!
1111
:caption: Contents:
1212

1313
jobSubmit.rst
14-
15-
Indices and tables
16-
==================
17-
18-
* :ref:`genindex`
19-
* :ref:`modindex`
20-
* :ref:`search`

‎docs/_build/html/_sources/jobSubmit.rst.txt

+6-5
Original file line numberDiff line numberDiff line change
@@ -41,15 +41,16 @@ StreamGraph生成的主要流程如下:
4141
SelectTransformation等等.具体的使用场景如下:
4242

4343
* PartitionTransformation:如果用户想要对DataStream进行keyby操作,得到一个KeyedStream,即需要对数据重新分区.首先,用户需要设置根据什么key进行
44-
分区,即KeySelector.然后在生成KeyedStream的过程中,会得到一个PartitionTransformation.PartitionTransformation中会对这条记录通过key进行计算,
44+
分区,即KeySelector.然后在生成KeyedStream的过程中,会得到一个PartitionTransformation.在PartitionTransformation中会对这条记录通过key进行计算,
4545
判断应该发往下游哪个节点,KeyGroup可以由maxParallism进行调整.
46+
* TwoInputTransformaion:指包含两个输入流,如inputStream1和inputStream2,加上这个Transformation的输出,及Operator即可得到一个完整的TwoInputTransformation.
4647

47-
Or automatically numbered:
48+
以上过程得到了transformations的List,接下来就可以通过StreamGraphGenerator生成完整的StreamGraph.
49+
生成StreamGraph时会遍历Transformation树,逐个对Transformation进行转化,具体的转化由transform()方法完成.transform最终都会调用transformXXX对
50+
具体的StreamTransformation进行转换.transformPartition则是创建VirtualNode而不是StreamNode.
4851

49-
#. Item 1
50-
#. Item 2
5152

52-
Inline Markup
53+
Client
5354
-------------
5455
Words can have *emphasis in italics* or be **bold** and you can define
5556
code samples with back quotes, like when you talk about a command: ``sudo``

‎docs/_build/html/example.html

+12-8
Original file line numberDiff line numberDiff line change
@@ -78,15 +78,11 @@
7878

7979

8080

81-
<!-- Local TOC -->
82-
<div class="local-toc"><ul>
83-
<li><a class="reference internal" href="#">This is a Title</a><ul>
84-
<li><a class="reference internal" href="#subject-subtitle">Subject Subtitle</a></li>
85-
<li><a class="reference internal" href="#inline-markup">Inline Markup</a></li>
81+
<p class="caption"><span class="caption-text">Contents:</span></p>
82+
<ul>
83+
<li class="toctree-l1"><a class="reference internal" href="jobSubmit.html">任务提交</a></li>
8684
</ul>
87-
</li>
88-
</ul>
89-
</div>
85+
9086

9187

9288
</div>
@@ -178,6 +174,14 @@ <h2>Inline Markup<a class="headerlink" href="#inline-markup" title="Permalink to
178174
code samples with back quotes, like when you talk about a command: <code class="docutils literal notranslate"><span class="pre">sudo</span></code>
179175
gives you super user powers!</p>
180176
</div>
177+
</div>
178+
<div class="section" id="indices-and-tables">
179+
<h1>Indices and tables<a class="headerlink" href="#indices-and-tables" title="Permalink to this headline"></a></h1>
180+
<ul class="simple">
181+
<li><p><a class="reference internal" href="genindex.html"><span class="std std-ref">Index</span></a></p></li>
182+
<li><p><a class="reference internal" href="py-modindex.html"><span class="std std-ref">Module Index</span></a></p></li>
183+
<li><p><a class="reference internal" href="search.html"><span class="std std-ref">Search Page</span></a></p></li>
184+
</ul>
181185
</div>
182186

183187

‎docs/_build/html/index.html

+1-9
Original file line numberDiff line numberDiff line change
@@ -153,19 +153,11 @@ <h1>Flink源码阅读文档!<a class="headerlink" href="#flink" title="Permalink
153153
<ul>
154154
<li class="toctree-l1"><a class="reference internal" href="jobSubmit.html">任务提交</a><ul>
155155
<li class="toctree-l2"><a class="reference internal" href="jobSubmit.html#streamgraph">生成StreamGraph</a></li>
156-
<li class="toctree-l2"><a class="reference internal" href="jobSubmit.html#inline-markup">Inline Markup</a></li>
156+
<li class="toctree-l2"><a class="reference internal" href="jobSubmit.html#client">Client</a></li>
157157
</ul>
158158
</li>
159159
</ul>
160160
</div>
161-
</div>
162-
<div class="section" id="indices-and-tables">
163-
<h1>Indices and tables<a class="headerlink" href="#indices-and-tables" title="Permalink to this headline"></a></h1>
164-
<ul class="simple">
165-
<li><p><a class="reference internal" href="genindex.html"><span class="std std-ref">Index</span></a></p></li>
166-
<li><p><a class="reference internal" href="py-modindex.html"><span class="std std-ref">Module Index</span></a></p></li>
167-
<li><p><a class="reference internal" href="search.html"><span class="std std-ref">Search Page</span></a></p></li>
168-
</ul>
169161
</div>
170162

171163

‎docs/_build/html/jobSubmit.html

+8-11
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@
8383
<ul class="current">
8484
<li class="toctree-l1 current"><a class="current reference internal" href="#">任务提交</a><ul>
8585
<li class="toctree-l2"><a class="reference internal" href="#streamgraph">生成StreamGraph</a></li>
86-
<li class="toctree-l2"><a class="reference internal" href="#inline-markup">Inline Markup</a></li>
86+
<li class="toctree-l2"><a class="reference internal" href="#client">Client</a></li>
8787
</ul>
8888
</li>
8989
</ul>
@@ -194,20 +194,17 @@ <h2>生成StreamGraph<a class="headerlink" href="#streamgraph" title="Permalink
194194
<blockquote>
195195
<div><ul class="simple">
196196
<li><p>PartitionTransformation:如果用户想要对DataStream进行keyby操作,得到一个KeyedStream,即需要对数据重新分区.首先,用户需要设置根据什么key进行
197-
分区,即KeySelector.然后在生成KeyedStream的过程中,会得到一个PartitionTransformation.PartitionTransformation中会对这条记录通过key进行计算,
197+
分区,即KeySelector.然后在生成KeyedStream的过程中,会得到一个PartitionTransformation.在PartitionTransformation中会对这条记录通过key进行计算,
198198
判断应该发往下游哪个节点,KeyGroup可以由maxParallism进行调整.</p></li>
199+
<li><p>TwoInputTransformaion:指包含两个输入流,如inputStream1和inputStream2,加上这个Transformation的输出,及Operator即可得到一个完整的TwoInputTransformation.</p></li>
199200
</ul>
200201
</div></blockquote>
201-
<p>Or automatically numbered:</p>
202-
<blockquote>
203-
<div><ol class="arabic simple">
204-
<li><p>Item 1</p></li>
205-
<li><p>Item 2</p></li>
206-
</ol>
207-
</div></blockquote>
202+
<p>以上过程得到了transformations的List,接下来就可以通过StreamGraphGenerator生成完整的StreamGraph.
203+
生成StreamGraph时会遍历Transformation树,逐个对Transformation进行转化,具体的转化由transform()方法完成.transform最终都会调用transformXXX对
204+
具体的StreamTransformation进行转换.transformPartition则是创建VirtualNode而不是StreamNode.</p>
208205
</div>
209-
<div class="section" id="inline-markup">
210-
<h2>Inline Markup<a class="headerlink" href="#inline-markup" title="Permalink to this headline"></a></h2>
206+
<div class="section" id="client">
207+
<h2>Client<a class="headerlink" href="#client" title="Permalink to this headline"></a></h2>
211208
<p>Words can have <em>emphasis in italics</em> or be <strong>bold</strong> and you can define
212209
code samples with back quotes, like when you talk about a command: <code class="docutils literal notranslate"><span class="pre">sudo</span></code>
213210
gives you super user powers!</p>

‎docs/_build/html/searchindex.js

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎docs/example.rst

+8-1
Original file line numberDiff line numberDiff line change
@@ -22,4 +22,11 @@ Inline Markup
2222
-------------
2323
Words can have *emphasis in italics* or be **bold** and you can define
2424
code samples with back quotes, like when you talk about a command: ``sudo``
25-
gives you super user powers!
25+
gives you super user powers!
26+
27+
Indices and tables
28+
==================
29+
30+
* :ref:`genindex`
31+
* :ref:`modindex`
32+
* :ref:`search`

‎docs/index.rst

-7
Original file line numberDiff line numberDiff line change
@@ -11,10 +11,3 @@ Flink源码阅读文档!
1111
:caption: Contents:
1212

1313
jobSubmit.rst
14-
15-
Indices and tables
16-
==================
17-
18-
* :ref:`genindex`
19-
* :ref:`modindex`
20-
* :ref:`search`

0 commit comments

Comments
 (0)