local/twitter-userstream-elasticsearch/src/main/resources/TwitterUserstreamElasticsearch.dot.svg - streams-examples - Git at Google

 <?xml version="1.0" encoding="UTF-8" standalone="no"?>
 <!--
   ~ Licensed to the Apache Software Foundation (ASF) under one
   ~ or more contributor license agreements.  See the NOTICE file
   ~ distributed with this work for additional information
   ~ regarding copyright ownership.  The ASF licenses this file
   ~ to you under the Apache License, Version 2.0 (the
   ~ "License"); you may not use this file except in compliance
   ~
   ~   http://www.apache.org/licenses/LICENSE-2.0
   ~
   ~ Unless required by applicable law or agreed to in writing,
   ~ software distributed under the License is distributed on an
   ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
   ~ KIND, either express or implied.  See the License for the
   ~ specific language governing permissions and limitations
   ~ under the License.
   -->
 <!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.20150411.0445 (20150411.0445)
  -->
 <!-- Title: g Pages: 1 -->
 <svg width="404pt" height="518pt"
  viewBox="0.00 0.00 403.71 518.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 514)">
 <title>g</title>
 <polygon fill="white" stroke="transparent" points="-4,4 -4,-514 399.711,-514 399.711,4 -4,4"/>
 <!-- TwitterStreamProvider -->
 <g id="node1" class="node"><title>TwitterStreamProvider</title>
 <g id="a_node1"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java" xlink:title="TwitterStreamProvider">
 <ellipse fill="none" stroke="black" cx="225.047" cy="-492" rx="91.0473" ry="18"/>
 <text text-anchor="middle" x="225.047" y="-487.8" font-family="Times,serif" font-size="14.00">TwitterStreamProvider</text>
 </a>
 </g>
 </g>
 <!-- ActivityConverterProcessor -->
 <g id="node2" class="node"><title>ActivityConverterProcessor</title>
 <g id="a_node2"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterProcessor.java" xlink:title="ActivityConverterProcessor">
 <polygon fill="none" stroke="black" points="311.344,-424 138.75,-424 138.75,-388 311.344,-388 311.344,-424"/>
 <text text-anchor="middle" x="225.047" y="-401.8" font-family="Times,serif" font-size="14.00">ActivityConverterProcessor</text>
 </a>
 </g>
 </g>
 <!-- TwitterStreamProvider&#45;&gt;ActivityConverterProcessor -->
 <g id="edge1" class="edge"><title>TwitterStreamProvider&#45;&gt;ActivityConverterProcessor</title>
 <path fill="none" stroke="black" d="M225.047,-473.762C225.047,-462.36 225.047,-447.434 225.047,-434.494"/>
 <polygon fill="black" stroke="black" points="228.547,-434.212 225.047,-424.212 221.547,-434.212 228.547,-434.212"/>
 <text text-anchor="middle" x="258.868" y="-444.8" font-family="Times,serif" font-size="14.00">ObjectNode</text>
 </g>
 <!-- DeleteOnlyProcessor -->
 <g id="node3" class="node"><title>DeleteOnlyProcessor</title>
 <g id="a_node3"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-components/streams-filters/src/main/java/org/apache/streams/filters/VerbDefinitionKeepFilter.java" xlink:title="VerbDefinitionKeepFilter (verb:delete)">
 <polygon fill="none" stroke="black" points="234.141,-338 -0.0468938,-338 -0.0468938,-302 234.141,-302 234.141,-338"/>
 <text text-anchor="middle" x="117.047" y="-315.8" font-family="Times,serif" font-size="14.00">VerbDefinitionKeepFilter (verb:delete)</text>
 </a>
 </g>
 </g>
 <!-- ActivityConverterProcessor&#45;&gt;DeleteOnlyProcessor -->
 <g id="edge2" class="edge"><title>ActivityConverterProcessor&#45;&gt;DeleteOnlyProcessor</title>
 <g id="a_edge2"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <path fill="none" stroke="black" d="M202.407,-387.972C186.566,-375.358 165.216,-358.357 147.832,-344.514"/>
 <polygon fill="black" stroke="black" points="149.66,-341.496 139.657,-338.005 145.3,-346.972 149.66,-341.496"/>
 </a>
 </g>
 <g id="a_edge2&#45;label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <text text-anchor="middle" x="200.988" y="-358.8" font-family="Times,serif" font-size="14.00">Activity</text>
 </a>
 </g>
 </g>
 <!-- NoDeletesProcessor -->
 <g id="node4" class="node"><title>NoDeletesProcessor</title>
 <g id="a_node4"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-components/streams-filters/src/main/java/org/apache/streams/filters/VerbDefinitionDropFilter.java" xlink:title="VerbDefinitionDropFilter (verb:delete)">
 <polygon fill="none" stroke="black" points="395.875,-284 162.219,-284 162.219,-248 395.875,-248 395.875,-284"/>
 <text text-anchor="middle" x="279.047" y="-261.8" font-family="Times,serif" font-size="14.00">VerbDefinitionDropFilter (verb:delete)</text>
 </a>
 </g>
 </g>
 <!-- ActivityConverterProcessor&#45;&gt;NoDeletesProcessor -->
 <g id="edge3" class="edge"><title>ActivityConverterProcessor&#45;&gt;NoDeletesProcessor</title>
 <g id="a_edge3"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <path fill="none" stroke="black" d="M231.996,-387.984C241.18,-364.174 257.454,-321.981 268.248,-293.998"/>
 <polygon fill="black" stroke="black" points="271.62,-294.981 271.953,-284.391 265.089,-292.462 271.62,-294.981"/>
 </a>
 </g>
 <g id="a_edge3&#45;label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <text text-anchor="middle" x="267.988" y="-358.8" font-family="Times,serif" font-size="14.00">Activity</text>
 </a>
 </g>
 </g>
 <!-- SetDeleteIdProcessor -->
 <g id="node5" class="node"><title>SetDeleteIdProcessor</title>
 <g id="a_node5"><a xlink:href="https://github.com/apache/incubator-streams-examples/blob/master/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/twitter/example/TwitterUserstreamElasticsearch.java" xlink:title="SetDeleteIdProcessor (verb:post)">
 <polygon fill="none" stroke="black" points="222.993,-230 21.1011,-230 21.1011,-194 222.993,-194 222.993,-230"/>
 <text text-anchor="middle" x="122.047" y="-207.8" font-family="Times,serif" font-size="14.00">SetDeleteIdProcessor (verb:post)</text>
 </a>
 </g>
 </g>
 <!-- DeleteOnlyProcessor&#45;&gt;SetDeleteIdProcessor -->
 <g id="edge4" class="edge"><title>DeleteOnlyProcessor&#45;&gt;SetDeleteIdProcessor</title>
 <g id="a_edge4"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <path fill="none" stroke="black" d="M111.056,-301.882C109.461,-296.221 107.96,-289.909 107.164,-284 105.027,-268.143 104.048,-263.694 107.164,-248 107.701,-245.295 108.445,-242.538 109.316,-239.814"/>
 <polygon fill="black" stroke="black" points="112.668,-240.842 112.884,-230.249 106.11,-238.395 112.668,-240.842"/>
 </a>
 </g>
 <g id="a_edge4&#45;label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <text text-anchor="middle" x="130.988" y="-261.8" font-family="Times,serif" font-size="14.00">Activity</text>
 </a>
 </g>
 </g>
 <!-- ElasticsearchPersistWriter -->
 <g id="node6" class="node"><title>ElasticsearchPersistWriter</title>
 <g id="a_node6"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java" xlink:title="ElasticsearchPersistWriter">
 <ellipse fill="none" stroke="black" cx="271.047" cy="-158" rx="103.134" ry="18"/>
 <text text-anchor="middle" x="271.047" y="-153.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistWriter</text>
 </a>
 </g>
 </g>
 <!-- NoDeletesProcessor&#45;&gt;ElasticsearchPersistWriter -->
 <g id="edge5" class="edge"><title>NoDeletesProcessor&#45;&gt;ElasticsearchPersistWriter</title>
 <g id="a_edge5"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <path fill="none" stroke="black" d="M277.69,-247.679C276.441,-230.821 274.57,-205.565 273.132,-186.147"/>
 <polygon fill="black" stroke="black" points="276.613,-185.764 272.384,-176.05 269.632,-186.281 276.613,-185.764"/>
 </a>
 </g>
 <g id="a_edge5&#45;label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <text text-anchor="middle" x="299.988" y="-207.8" font-family="Times,serif" font-size="14.00">Activity</text>
 </a>
 </g>
 </g>
 <!-- ElasticsearchPersistDeleter -->
 <g id="node7" class="node"><title>ElasticsearchPersistDeleter</title>
 <g id="a_node7"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistDeleter.java" xlink:title="ElasticsearchPersistDeleter">
 <ellipse fill="none" stroke="black" cx="127.047" cy="-104" rx="106.223" ry="18"/>
 <text text-anchor="middle" x="127.047" y="-99.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistDeleter</text>
 </a>
 </g>
 </g>
 <!-- SetDeleteIdProcessor&#45;&gt;ElasticsearchPersistDeleter -->
 <g id="edge7" class="edge"><title>SetDeleteIdProcessor&#45;&gt;ElasticsearchPersistDeleter</title>
 <g id="a_edge7"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/delete.json" xlink:title="Delete">
 <path fill="none" stroke="black" d="M121.572,-193.929C121.331,-179.354 121.306,-158.336 122.516,-140 122.682,-137.47 122.909,-134.846 123.172,-132.219"/>
 <polygon fill="black" stroke="black" points="126.65,-132.609 124.32,-122.274 119.696,-131.806 126.65,-132.609"/>
 </a>
 </g>
 <g id="a_edge7&#45;label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/delete.json" xlink:title="Delete">
 <text text-anchor="middle" x="141.312" y="-153.8" font-family="Times,serif" font-size="14.00">Delete</text>
 </a>
 </g>
 </g>
 <!-- es -->
 <g id="node8" class="node"><title>es</title>
 <polygon fill="none" stroke="black" points="283.854,-36 158.24,-36 158.24,-0 283.854,-0 283.854,-36"/>
 <text text-anchor="middle" x="221.047" y="-13.8" font-family="Times,serif" font-size="14.00">es://{index}/{type}</text>
 </g>
 <!-- ElasticsearchPersistWriter&#45;&gt;es -->
 <g id="edge6" class="edge"><title>ElasticsearchPersistWriter&#45;&gt;es</title>
 <g id="a_edge6"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <path fill="none" stroke="black" d="M264.613,-139.984C256.109,-116.174 241.04,-73.981 231.046,-45.9977"/>
 <polygon fill="black" stroke="black" points="234.275,-44.6316 227.615,-36.3914 227.683,-46.986 234.275,-44.6316"/>
 </a>
 </g>
 <g id="a_edge6&#45;label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
 <text text-anchor="middle" x="280.988" y="-99.8" font-family="Times,serif" font-size="14.00">Activity</text>
 </a>
 </g>
 </g>
 <!-- ElasticsearchPersistDeleter&#45;&gt;es -->
 <g id="edge8" class="edge"><title>ElasticsearchPersistDeleter&#45;&gt;es</title>
 <g id="a_edge8"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/delete.json" xlink:title="Delete">
 <path fill="none" stroke="black" d="M146.524,-86.1807C160.17,-73.6957 178.596,-56.8378 193.712,-43.0087"/>
 <polygon fill="black" stroke="black" points="196.256,-45.4248 201.272,-36.0923 191.531,-40.2601 196.256,-45.4248"/>
 </a>
 </g>
 <g id="a_edge8&#45;label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/delete.json" xlink:title="Delete">
 <text text-anchor="middle" x="198.312" y="-56.8" font-family="Times,serif" font-size="14.00">Delete</text>
 </a>
 </g>
 </g>
 </g>
 </svg>
	<?xml version="1.0" encoding="UTF-8" standalone="no"?>
	<!--
	~ Licensed to the Apache Software Foundation (ASF) under one
	~ or more contributor license agreements. See the NOTICE file
	~ distributed with this work for additional information
	~ regarding copyright ownership. The ASF licenses this file
	~ to you under the Apache License, Version 2.0 (the
	~ "License"); you may not use this file except in compliance
	~
	~ http://www.apache.org/licenses/LICENSE-2.0
	~
	~ Unless required by applicable law or agreed to in writing,
	~ software distributed under the License is distributed on an
	~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
	~ KIND, either express or implied. See the License for the
	~ specific language governing permissions and limitations
	~ under the License.
	-->
	<!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.20150411.0445 (20150411.0445)
	-->
	<!-- Title: g Pages: 1 -->
	<svg width="404pt" height="518pt"
	viewBox="0.00 0.00 403.71 518.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 514)">
	<title>g</title>
	<polygon fill="white" stroke="transparent" points="-4,4 -4,-514 399.711,-514 399.711,4 -4,4"/>
	<!-- TwitterStreamProvider -->
	<g id="node1" class="node"><title>TwitterStreamProvider</title>
	<g id="a_node1"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java" xlink:title="TwitterStreamProvider">
	<ellipse fill="none" stroke="black" cx="225.047" cy="-492" rx="91.0473" ry="18"/>
	<text text-anchor="middle" x="225.047" y="-487.8" font-family="Times,serif" font-size="14.00">TwitterStreamProvider</text>
	</a>
	</g>
	</g>
	<!-- ActivityConverterProcessor -->
	<g id="node2" class="node"><title>ActivityConverterProcessor</title>
	<g id="a_node2"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterProcessor.java" xlink:title="ActivityConverterProcessor">
	<polygon fill="none" stroke="black" points="311.344,-424 138.75,-424 138.75,-388 311.344,-388 311.344,-424"/>
	<text text-anchor="middle" x="225.047" y="-401.8" font-family="Times,serif" font-size="14.00">ActivityConverterProcessor</text>
	</a>
	</g>
	</g>
	<!-- TwitterStreamProvider->ActivityConverterProcessor -->
	<g id="edge1" class="edge"><title>TwitterStreamProvider->ActivityConverterProcessor</title>
	<path fill="none" stroke="black" d="M225.047,-473.762C225.047,-462.36 225.047,-447.434 225.047,-434.494"/>
	<polygon fill="black" stroke="black" points="228.547,-434.212 225.047,-424.212 221.547,-434.212 228.547,-434.212"/>
	<text text-anchor="middle" x="258.868" y="-444.8" font-family="Times,serif" font-size="14.00">ObjectNode</text>
	</g>
	<!-- DeleteOnlyProcessor -->
	<g id="node3" class="node"><title>DeleteOnlyProcessor</title>
	<g id="a_node3"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-components/streams-filters/src/main/java/org/apache/streams/filters/VerbDefinitionKeepFilter.java" xlink:title="VerbDefinitionKeepFilter (verb:delete)">
	<polygon fill="none" stroke="black" points="234.141,-338 -0.0468938,-338 -0.0468938,-302 234.141,-302 234.141,-338"/>
	<text text-anchor="middle" x="117.047" y="-315.8" font-family="Times,serif" font-size="14.00">VerbDefinitionKeepFilter (verb:delete)</text>
	</a>
	</g>
	</g>
	<!-- ActivityConverterProcessor->DeleteOnlyProcessor -->
	<g id="edge2" class="edge"><title>ActivityConverterProcessor->DeleteOnlyProcessor</title>
	<g id="a_edge2"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<path fill="none" stroke="black" d="M202.407,-387.972C186.566,-375.358 165.216,-358.357 147.832,-344.514"/>
	<polygon fill="black" stroke="black" points="149.66,-341.496 139.657,-338.005 145.3,-346.972 149.66,-341.496"/>
	</a>
	</g>
	<g id="a_edge2-label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<text text-anchor="middle" x="200.988" y="-358.8" font-family="Times,serif" font-size="14.00">Activity</text>
	</a>
	</g>
	</g>
	<!-- NoDeletesProcessor -->
	<g id="node4" class="node"><title>NoDeletesProcessor</title>
	<g id="a_node4"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-components/streams-filters/src/main/java/org/apache/streams/filters/VerbDefinitionDropFilter.java" xlink:title="VerbDefinitionDropFilter (verb:delete)">
	<polygon fill="none" stroke="black" points="395.875,-284 162.219,-284 162.219,-248 395.875,-248 395.875,-284"/>
	<text text-anchor="middle" x="279.047" y="-261.8" font-family="Times,serif" font-size="14.00">VerbDefinitionDropFilter (verb:delete)</text>
	</a>
	</g>
	</g>
	<!-- ActivityConverterProcessor->NoDeletesProcessor -->
	<g id="edge3" class="edge"><title>ActivityConverterProcessor->NoDeletesProcessor</title>
	<g id="a_edge3"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<path fill="none" stroke="black" d="M231.996,-387.984C241.18,-364.174 257.454,-321.981 268.248,-293.998"/>
	<polygon fill="black" stroke="black" points="271.62,-294.981 271.953,-284.391 265.089,-292.462 271.62,-294.981"/>
	</a>
	</g>
	<g id="a_edge3-label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<text text-anchor="middle" x="267.988" y="-358.8" font-family="Times,serif" font-size="14.00">Activity</text>
	</a>
	</g>
	</g>
	<!-- SetDeleteIdProcessor -->
	<g id="node5" class="node"><title>SetDeleteIdProcessor</title>
	<g id="a_node5"><a xlink:href="https://github.com/apache/incubator-streams-examples/blob/master/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/twitter/example/TwitterUserstreamElasticsearch.java" xlink:title="SetDeleteIdProcessor (verb:post)">
	<polygon fill="none" stroke="black" points="222.993,-230 21.1011,-230 21.1011,-194 222.993,-194 222.993,-230"/>
	<text text-anchor="middle" x="122.047" y="-207.8" font-family="Times,serif" font-size="14.00">SetDeleteIdProcessor (verb:post)</text>
	</a>
	</g>
	</g>
	<!-- DeleteOnlyProcessor->SetDeleteIdProcessor -->
	<g id="edge4" class="edge"><title>DeleteOnlyProcessor->SetDeleteIdProcessor</title>
	<g id="a_edge4"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<path fill="none" stroke="black" d="M111.056,-301.882C109.461,-296.221 107.96,-289.909 107.164,-284 105.027,-268.143 104.048,-263.694 107.164,-248 107.701,-245.295 108.445,-242.538 109.316,-239.814"/>
	<polygon fill="black" stroke="black" points="112.668,-240.842 112.884,-230.249 106.11,-238.395 112.668,-240.842"/>
	</a>
	</g>
	<g id="a_edge4-label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<text text-anchor="middle" x="130.988" y="-261.8" font-family="Times,serif" font-size="14.00">Activity</text>
	</a>
	</g>
	</g>
	<!-- ElasticsearchPersistWriter -->
	<g id="node6" class="node"><title>ElasticsearchPersistWriter</title>
	<g id="a_node6"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java" xlink:title="ElasticsearchPersistWriter">
	<ellipse fill="none" stroke="black" cx="271.047" cy="-158" rx="103.134" ry="18"/>
	<text text-anchor="middle" x="271.047" y="-153.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistWriter</text>
	</a>
	</g>
	</g>
	<!-- NoDeletesProcessor->ElasticsearchPersistWriter -->
	<g id="edge5" class="edge"><title>NoDeletesProcessor->ElasticsearchPersistWriter</title>
	<g id="a_edge5"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<path fill="none" stroke="black" d="M277.69,-247.679C276.441,-230.821 274.57,-205.565 273.132,-186.147"/>
	<polygon fill="black" stroke="black" points="276.613,-185.764 272.384,-176.05 269.632,-186.281 276.613,-185.764"/>
	</a>
	</g>
	<g id="a_edge5-label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<text text-anchor="middle" x="299.988" y="-207.8" font-family="Times,serif" font-size="14.00">Activity</text>
	</a>
	</g>
	</g>
	<!-- ElasticsearchPersistDeleter -->
	<g id="node7" class="node"><title>ElasticsearchPersistDeleter</title>
	<g id="a_node7"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistDeleter.java" xlink:title="ElasticsearchPersistDeleter">
	<ellipse fill="none" stroke="black" cx="127.047" cy="-104" rx="106.223" ry="18"/>
	<text text-anchor="middle" x="127.047" y="-99.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistDeleter</text>
	</a>
	</g>
	</g>
	<!-- SetDeleteIdProcessor->ElasticsearchPersistDeleter -->
	<g id="edge7" class="edge"><title>SetDeleteIdProcessor->ElasticsearchPersistDeleter</title>
	<g id="a_edge7"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/delete.json" xlink:title="Delete">
	<path fill="none" stroke="black" d="M121.572,-193.929C121.331,-179.354 121.306,-158.336 122.516,-140 122.682,-137.47 122.909,-134.846 123.172,-132.219"/>
	<polygon fill="black" stroke="black" points="126.65,-132.609 124.32,-122.274 119.696,-131.806 126.65,-132.609"/>
	</a>
	</g>
	<g id="a_edge7-label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/delete.json" xlink:title="Delete">
	<text text-anchor="middle" x="141.312" y="-153.8" font-family="Times,serif" font-size="14.00">Delete</text>
	</a>
	</g>
	</g>
	<!-- es -->
	<g id="node8" class="node"><title>es</title>
	<polygon fill="none" stroke="black" points="283.854,-36 158.24,-36 158.24,-0 283.854,-0 283.854,-36"/>
	<text text-anchor="middle" x="221.047" y="-13.8" font-family="Times,serif" font-size="14.00">es://{index}/{type}</text>
	</g>
	<!-- ElasticsearchPersistWriter->es -->
	<g id="edge6" class="edge"><title>ElasticsearchPersistWriter->es</title>
	<g id="a_edge6"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<path fill="none" stroke="black" d="M264.613,-139.984C256.109,-116.174 241.04,-73.981 231.046,-45.9977"/>
	<polygon fill="black" stroke="black" points="234.275,-44.6316 227.615,-36.3914 227.683,-46.986 234.275,-44.6316"/>
	</a>
	</g>
	<g id="a_edge6-label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json" xlink:title="Activity">
	<text text-anchor="middle" x="280.988" y="-99.8" font-family="Times,serif" font-size="14.00">Activity</text>
	</a>
	</g>
	</g>
	<!-- ElasticsearchPersistDeleter->es -->
	<g id="edge8" class="edge"><title>ElasticsearchPersistDeleter->es</title>
	<g id="a_edge8"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/delete.json" xlink:title="Delete">
	<path fill="none" stroke="black" d="M146.524,-86.1807C160.17,-73.6957 178.596,-56.8378 193.712,-43.0087"/>
	<polygon fill="black" stroke="black" points="196.256,-45.4248 201.272,-36.0923 191.531,-40.2601 196.256,-45.4248"/>
	</a>
	</g>
	<g id="a_edge8-label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/delete.json" xlink:title="Delete">
	<text text-anchor="middle" x="198.312" y="-56.8" font-family="Times,serif" font-size="14.00">Delete</text>
	</a>
	</g>
	</g>
	</g>
	</svg>