forked from AntBranch/awesome-github
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathUntitled Diagram.drawio
85 lines (85 loc) · 8.54 KB
/
Untitled Diagram.drawio
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
<mxfile host="app.diagrams.net" modified="2021-12-22T13:29:20.281Z" agent="5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.110 Safari/537.36" etag="-EGbeyBPSiAT5TAysrWF" version="16.0.3" type="github">
<diagram id="C5RBs43oDa-KdzZeNtuy" name="Page-1">
<mxGraphModel dx="638" dy="334" grid="1" gridSize="10" guides="1" tooltips="1" connect="1" arrows="1" fold="1" page="1" pageScale="1" pageWidth="827" pageHeight="1169" math="0" shadow="0">
<root>
<mxCell id="WIyWlLk6GJQsqaUBKTNV-0" />
<mxCell id="WIyWlLk6GJQsqaUBKTNV-1" parent="WIyWlLk6GJQsqaUBKTNV-0" />
<mxCell id="zKDFTO2ErB2MMYt_Se-R-21" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;exitX=1;exitY=0.5;exitDx=0;exitDy=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="WIyWlLk6GJQsqaUBKTNV-3" target="zKDFTO2ErB2MMYt_Se-R-4" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="WIyWlLk6GJQsqaUBKTNV-3" value="创建广播流<br>类型描述器" style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="160" y="80" width="120" height="40" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-5" value="" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="zKDFTO2ErB2MMYt_Se-R-0" target="zKDFTO2ErB2MMYt_Se-R-4" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-0" value="创建dataStream" style="whiteSpace=wrap;html=1;rounded=1;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="160" y="190" width="120" height="60" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-8" value="" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="zKDFTO2ErB2MMYt_Se-R-4" target="zKDFTO2ErB2MMYt_Se-R-7" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-4" value="broadcast()<br>生成广播流" style="whiteSpace=wrap;html=1;rounded=1;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="360" y="190" width="120" height="60" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-9" value="" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="zKDFTO2ErB2MMYt_Se-R-6" target="zKDFTO2ErB2MMYt_Se-R-7" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-6" value="创建dataStream/<br>keyedStream" style="rounded=1;whiteSpace=wrap;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="160" y="320" width="120" height="60" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-11" value="BroadcastProcessFunction<br><span style="font-size: 11px">KeyedBroadcastProcessFunction</span>" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="zKDFTO2ErB2MMYt_Se-R-7" target="zKDFTO2ErB2MMYt_Se-R-10" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-16" value="" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="zKDFTO2ErB2MMYt_Se-R-7" target="zKDFTO2ErB2MMYt_Se-R-14" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-7" value="connect()<br>结合广播流和数据流" style="whiteSpace=wrap;html=1;rounded=1;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="360" y="320" width="120" height="60" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-13" value="" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="zKDFTO2ErB2MMYt_Se-R-10" target="zKDFTO2ErB2MMYt_Se-R-12" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-10" value="定义实现类内部状态存储广播状态" style="whiteSpace=wrap;html=1;rounded=1;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="360" y="460" width="120" height="60" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-17" value="" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;startArrow=none;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="zKDFTO2ErB2MMYt_Se-R-18" target="zKDFTO2ErB2MMYt_Se-R-14" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-19" value="" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="zKDFTO2ErB2MMYt_Se-R-12" target="zKDFTO2ErB2MMYt_Se-R-18" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-12" value="processBroadcastElement()<br>处理广播流状态变更<br>写入自定义内部状态或<br>在上下文中改变" style="whiteSpace=wrap;html=1;rounded=1;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="330" y="585" width="180" height="60" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-14" value="processElement()<br>处理数据流数据" style="whiteSpace=wrap;html=1;rounded=1;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="590" y="320" width="120" height="60" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-18" value="访问自定义内部状态<br>或者<br>上下文中getBroadcastState" style="whiteSpace=wrap;html=1;rounded=1;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="575" y="587.5" width="150" height="55" as="geometry" />
</mxCell>
<mxCell id="zKDFTO2ErB2MMYt_Se-R-20" value="" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;endArrow=none;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="zKDFTO2ErB2MMYt_Se-R-12" target="zKDFTO2ErB2MMYt_Se-R-18" edge="1">
<mxGeometry relative="1" as="geometry">
<mxPoint x="510" y="615" as="sourcePoint" />
<mxPoint x="650" y="380" as="targetPoint" />
</mxGeometry>
</mxCell>
<mxCell id="rYq67QuEyJFvKg4vDMKm-6" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;exitX=1;exitY=0.5;exitDx=0;exitDy=0;entryX=0.5;entryY=0;entryDx=0;entryDy=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="rYq67QuEyJFvKg4vDMKm-0" target="rYq67QuEyJFvKg4vDMKm-3" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="rYq67QuEyJFvKg4vDMKm-0" value="必选参数：<br>List&lt;List&lt;topics&gt;&gt;<br>T<br>flink env" style="rounded=1;whiteSpace=wrap;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="140" y="760" width="150" height="70" as="geometry" />
</mxCell>
<mxCell id="rYq67QuEyJFvKg4vDMKm-5" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;exitX=1;exitY=0.5;exitDx=0;exitDy=0;entryX=0.5;entryY=1;entryDx=0;entryDy=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="rYq67QuEyJFvKg4vDMKm-1" target="rYq67QuEyJFvKg4vDMKm-3" edge="1">
<mxGeometry relative="1" as="geometry" />
</mxCell>
<mxCell id="rYq67QuEyJFvKg4vDMKm-1" value="可选参数：<br>brokers url<br>client params<br>serializer" style="rounded=1;whiteSpace=wrap;html=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="160" y="870" width="120" height="60" as="geometry" />
</mxCell>
<mxCell id="rYq67QuEyJFvKg4vDMKm-3" value="DataStream&lt;T&gt;" style="whiteSpace=wrap;html=1;rounded=1;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
<mxGeometry x="360" y="820" width="120" height="60" as="geometry" />
</mxCell>
</root>
</mxGraphModel>
</diagram>
</mxfile>