flink/flink-twitter-collection/src/main/resources/FlinkTwitterPostsPipeline.dot.svg

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<!DOCTYPE svg PUBLIC "-//W3C//DTD SVG 1.1//EN"
 "http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd">
<!-- Generated by graphviz version 2.39.20160214.2135 (20160214.2135)
 -->
<!-- Title: g Pages: 1 -->
<svg width="504pt" height="203pt"
 viewBox="0.00 0.00 504.29 203.00" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink">
<g id="graph0" class="graph" transform="scale(1 1) rotate(0) translate(4 199)">
<title>g</title>
<polygon fill="white" stroke="transparent" points="-4,4 -4,-199 500.286,-199 500.286,4 -4,4"/>
<!-- source -->
<g id="node1" class="node">
<title>source</title>
<polygon fill="none" stroke="black" points="275.082,-109 11.9727,-109 11.9727,-113 -0.0273492,-113 -0.0273492,-73 275.082,-73 275.082,-109"/>
<polyline fill="none" stroke="black" points="-0.0273492,-109 11.9727,-109 "/>
<text text-anchor="middle" x="137.527" y="-93.8" font-family="Times,serif" font-size="14.00">source</text>
<text text-anchor="middle" x="137.527" y="-79.8" font-family="Times,serif" font-size="14.00">hdfs://${host}:${port}/${path}/${readerPath}</text>
</g>
<!-- TwitterTimelineProvider -->
<g id="node2" class="node">
<title>TwitterTimelineProvider</title>
<g id="a_node2"><a xlink:href="https://github.com/apache/streams/blob/master/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java" xlink:title="TwitterTimelineProvider">
<ellipse fill="none" stroke="black" cx="200.527" cy="-177" rx="97.6831" ry="18"/>
<text text-anchor="middle" x="200.527" y="-172.8" font-family="Times,serif" font-size="14.00">TwitterTimelineProvider</text>
</a>
</g>
</g>
<!-- TwitterTimelineProvider&#45;&gt;source -->
<g id="edge1" class="edge">
<title>TwitterTimelineProvider&#45;&gt;source</title>
<path fill="none" stroke="black" stroke-dasharray="5,2" d="M181.043,-150.402C171.25,-137.034 159.635,-121.178 150.869,-109.212"/>
<polygon fill="black" stroke="black" points="178.434,-152.763 187.167,-158.762 184.081,-148.626 178.434,-152.763"/>
</g>
<!-- RollingFileSink -->
<g id="node3" class="node">
<title>RollingFileSink</title>
<ellipse fill="none" stroke="black" cx="359.527" cy="-91" rx="66.7358" ry="18"/>
<text text-anchor="middle" x="359.527" y="-86.8" font-family="Times,serif" font-size="14.00">RollingFileSink</text>
</g>
<!-- TwitterTimelineProvider&#45;&gt;RollingFileSink -->
<g id="edge2" class="edge">
<title>TwitterTimelineProvider&#45;&gt;RollingFileSink</title>
<path fill="none" stroke="black" d="M232.321,-159.803C257.806,-146.019 293.67,-126.621 320.824,-111.934"/>
<polygon fill="black" stroke="black" points="322.54,-114.985 329.671,-107.149 319.21,-108.828 322.54,-114.985"/>
<text text-anchor="middle" x="306.641" y="-129.8" font-family="Times,serif" font-size="14.00">String</text>
</g>
<!-- destination -->
<g id="node4" class="node">
<title>destination</title>
<polygon fill="none" stroke="black" points="496.044,-36 235.01,-36 235.01,-40 223.01,-40 223.01,-0 496.044,-0 496.044,-36"/>
<polyline fill="none" stroke="black" points="223.01,-36 235.01,-36 "/>
<text text-anchor="middle" x="359.527" y="-20.8" font-family="Times,serif" font-size="14.00">destination</text>
<text text-anchor="middle" x="359.527" y="-6.8" font-family="Times,serif" font-size="14.00">hdfs://${host}:${port}/${path}/${writerPath}</text>
</g>
<!-- RollingFileSink&#45;&gt;destination -->
<g id="edge3" class="edge">
<title>RollingFileSink&#45;&gt;destination</title>
<path fill="none" stroke="black" d="M359.527,-72.9551C359.527,-64.8828 359.527,-55.1764 359.527,-46.1817"/>
<polygon fill="black" stroke="black" points="363.027,-46.0903 359.527,-36.0904 356.027,-46.0904 363.027,-46.0903"/>
</g>
</g>
</svg>