You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2015/05/16 21:59:07 UTC
[09/11] incubator-streams-examples git commit: add svg files
add svg files
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/commit/558ef157
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/tree/558ef157
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/diff/558ef157
Branch: refs/heads/0.2-incubating-rc1
Commit: 558ef157c3815f5dac4c13361a0c1d06fe7e32f7
Parents: 113d671
Author: Steve Blackmon <sb...@apache.org>
Authored: Sat May 9 13:20:28 2015 -0500
Committer: Steve Blackmon <sb...@apache.org>
Committed: Sat May 9 13:20:28 2015 -0500
----------------------------------------------------------------------
.gitignore | 2 +-
.../main/resources/ElasticsearchHdfs.dot.svg | 55 +++++++
.../main/resources/HdfsElasticsearch.dot.svg | 55 +++++++
.../main/resources/ElasticsearchReindex.dot.svg | 55 +++++++
.../resources/MongoElasticsearchSync.dot.svg | 57 +++++++
.../main/resources/TwitterFollowGraph.dot.svg | 85 ++++++++++
.../TwitterHistoryElasticsearch.dot.svg | 72 ++++++++
.../TwitterUserstreamElasticsearch.dot.svg | 164 +++++++++++++++++++
pom.xml | 6 +-
9 files changed, 548 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/558ef157/.gitignore
----------------------------------------------------------------------
diff --git a/.gitignore b/.gitignore
index 0600e2b..9062619 100644
--- a/.gitignore
+++ b/.gitignore
@@ -5,7 +5,7 @@ streams-master-pom/
target/
overlays/
-src/site/resources/
+**/src/site/resources/
dependency-reduced-pom.xml
# IDE directories/files #
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/558ef157/local/elasticsearch-hdfs/src/main/resources/ElasticsearchHdfs.dot.svg
----------------------------------------------------------------------
diff --git a/local/elasticsearch-hdfs/src/main/resources/ElasticsearchHdfs.dot.svg b/local/elasticsearch-hdfs/src/main/resources/ElasticsearchHdfs.dot.svg
new file mode 100644
index 0000000..2ae7c48
--- /dev/null
+++ b/local/elasticsearch-hdfs/src/main/resources/ElasticsearchHdfs.dot.svg
@@ -0,0 +1,55 @@
+<?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.20150411.0445 (20150411.0445)
+ -->
+<!-- Title: g Pages: 1 -->
+<svg width="219pt" height="276pt"
+ viewBox="0.00 0.00 218.76 276.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 272)">
+<title>g</title>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-272 214.763,-272 214.763,4 -4,4"/>
+<!-- ElasticsearchPersistReader -->
+<g id="node1" class="node"><title>ElasticsearchPersistReader</title>
+<g id="a_node1"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-provider-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReader.java" xlink:title="ElasticsearchPersistReader">
+<ellipse fill="none" stroke="black" cx="105.381" cy="-177" rx="105.263" ry="18"/>
+<text text-anchor="middle" x="105.381" y="-172.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistReader</text>
+</a>
+</g>
+</g>
+<!-- WebHdfsPersistWriter -->
+<g id="node2" class="node"><title>WebHdfsPersistWriter</title>
+<g id="a_node2"><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="WebHdfsPersistWriter">
+<ellipse fill="none" stroke="black" cx="105.381" cy="-91" rx="89.7062" ry="18"/>
+<text text-anchor="middle" x="105.381" y="-86.8" font-family="Times,serif" font-size="14.00">WebHdfsPersistWriter</text>
+</a>
+</g>
+</g>
+<!-- ElasticsearchPersistReader->WebHdfsPersistWriter -->
+<g id="edge2" class="edge"><title>ElasticsearchPersistReader->WebHdfsPersistWriter</title>
+<path fill="none" stroke="black" d="M105.381,-158.762C105.381,-147.36 105.381,-132.434 105.381,-119.494"/>
+<polygon fill="black" stroke="black" points="108.881,-119.212 105.381,-109.212 101.881,-119.212 108.881,-119.212"/>
+<text text-anchor="middle" x="122.495" 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="174.136,-36 36.6262,-36 36.6262,-0 174.136,-0 174.136,-36"/>
+<text text-anchor="middle" x="105.381" y="-13.8" font-family="Times,serif" font-size="14.00">hdfs://{index}/{type}</text>
+</g>
+<!-- WebHdfsPersistWriter->destination -->
+<g id="edge3" class="edge"><title>WebHdfsPersistWriter->destination</title>
+<path fill="none" stroke="black" d="M105.381,-72.9551C105.381,-64.8828 105.381,-55.1764 105.381,-46.1817"/>
+<polygon fill="black" stroke="black" points="108.881,-46.0903 105.381,-36.0904 101.881,-46.0904 108.881,-46.0903"/>
+</g>
+<!-- source -->
+<g id="node3" class="node"><title>source</title>
+<polygon fill="none" stroke="black" points="176.799,-268 33.9637,-268 33.9637,-232 176.799,-232 176.799,-268"/>
+<text text-anchor="middle" x="105.381" y="-245.8" font-family="Times,serif" font-size="14.00">es://{indexes}/{types}</text>
+</g>
+<!-- source->ElasticsearchPersistReader -->
+<g id="edge1" class="edge"><title>source->ElasticsearchPersistReader</title>
+<path fill="none" stroke="black" d="M105.381,-231.955C105.381,-223.883 105.381,-214.176 105.381,-205.182"/>
+<polygon fill="black" stroke="black" points="108.881,-205.09 105.381,-195.09 101.881,-205.09 108.881,-205.09"/>
+</g>
+</g>
+</svg>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/558ef157/local/elasticsearch-hdfs/src/main/resources/HdfsElasticsearch.dot.svg
----------------------------------------------------------------------
diff --git a/local/elasticsearch-hdfs/src/main/resources/HdfsElasticsearch.dot.svg b/local/elasticsearch-hdfs/src/main/resources/HdfsElasticsearch.dot.svg
new file mode 100644
index 0000000..814a3a5
--- /dev/null
+++ b/local/elasticsearch-hdfs/src/main/resources/HdfsElasticsearch.dot.svg
@@ -0,0 +1,55 @@
+<?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.20150411.0445 (20150411.0445)
+ -->
+<!-- Title: g Pages: 1 -->
+<svg width="214pt" height="276pt"
+ viewBox="0.00 0.00 214.13 276.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 272)">
+<title>g</title>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-272 210.134,-272 210.134,4 -4,4"/>
+<!-- WebHdfsPersistReader -->
+<g id="node1" class="node"><title>WebHdfsPersistReader</title>
+<g id="a_node1"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-provider-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReader.java" xlink:title="WebHdfsPersistReader">
+<ellipse fill="none" stroke="black" cx="103.067" cy="-177" rx="91.8351" ry="18"/>
+<text text-anchor="middle" x="103.067" y="-172.8" font-family="Times,serif" font-size="14.00">WebHdfsPersistReader</text>
+</a>
+</g>
+</g>
+<!-- ElasticsearchPersistWriter -->
+<g id="node2" class="node"><title>ElasticsearchPersistWriter</title>
+<g id="a_node2"><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="103.067" cy="-91" rx="103.134" ry="18"/>
+<text text-anchor="middle" x="103.067" y="-86.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistWriter</text>
+</a>
+</g>
+</g>
+<!-- WebHdfsPersistReader->ElasticsearchPersistWriter -->
+<g id="edge2" class="edge"><title>WebHdfsPersistReader->ElasticsearchPersistWriter</title>
+<path fill="none" stroke="black" d="M103.067,-158.762C103.067,-147.36 103.067,-132.434 103.067,-119.494"/>
+<polygon fill="black" stroke="black" points="106.567,-119.212 103.067,-109.212 99.5669,-119.212 106.567,-119.212"/>
+<text text-anchor="middle" x="120.181" 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="165.874,-36 40.2598,-36 40.2598,-0 165.874,-0 165.874,-36"/>
+<text text-anchor="middle" x="103.067" y="-13.8" font-family="Times,serif" font-size="14.00">es://{index}/{type}</text>
+</g>
+<!-- ElasticsearchPersistWriter->destination -->
+<g id="edge3" class="edge"><title>ElasticsearchPersistWriter->destination</title>
+<path fill="none" stroke="black" d="M103.067,-72.9551C103.067,-64.8828 103.067,-55.1764 103.067,-46.1817"/>
+<polygon fill="black" stroke="black" points="106.567,-46.0903 103.067,-36.0904 99.5669,-46.0904 106.567,-46.0903"/>
+</g>
+<!-- source -->
+<g id="node3" class="node"><title>source</title>
+<polygon fill="none" stroke="black" points="180.432,-268 25.7016,-268 25.7016,-232 180.432,-232 180.432,-268"/>
+<text text-anchor="middle" x="103.067" y="-245.8" font-family="Times,serif" font-size="14.00">hdfs://{indexes}/{types}</text>
+</g>
+<!-- source->WebHdfsPersistReader -->
+<g id="edge1" class="edge"><title>source->WebHdfsPersistReader</title>
+<path fill="none" stroke="black" d="M103.067,-231.955C103.067,-223.883 103.067,-214.176 103.067,-205.182"/>
+<polygon fill="black" stroke="black" points="106.567,-205.09 103.067,-195.09 99.5669,-205.09 106.567,-205.09"/>
+</g>
+</g>
+</svg>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/558ef157/local/elasticsearch-reindex/src/main/resources/ElasticsearchReindex.dot.svg
----------------------------------------------------------------------
diff --git a/local/elasticsearch-reindex/src/main/resources/ElasticsearchReindex.dot.svg b/local/elasticsearch-reindex/src/main/resources/ElasticsearchReindex.dot.svg
new file mode 100644
index 0000000..7ef946a
--- /dev/null
+++ b/local/elasticsearch-reindex/src/main/resources/ElasticsearchReindex.dot.svg
@@ -0,0 +1,55 @@
+<?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.20150411.0445 (20150411.0445)
+ -->
+<!-- Title: g Pages: 1 -->
+<svg width="219pt" height="276pt"
+ viewBox="0.00 0.00 218.76 276.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 272)">
+<title>g</title>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-272 214.763,-272 214.763,4 -4,4"/>
+<!-- ElasticsearchPersistReader -->
+<g id="node1" class="node"><title>ElasticsearchPersistReader</title>
+<g id="a_node1"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-provider-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReader.java" xlink:title="ElasticsearchPersistReader">
+<ellipse fill="none" stroke="black" cx="105.381" cy="-177" rx="105.263" ry="18"/>
+<text text-anchor="middle" x="105.381" y="-172.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistReader</text>
+</a>
+</g>
+</g>
+<!-- ElasticsearchPersistWriter -->
+<g id="node2" class="node"><title>ElasticsearchPersistWriter</title>
+<g id="a_node2"><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="105.381" cy="-91" rx="103.134" ry="18"/>
+<text text-anchor="middle" x="105.381" y="-86.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistWriter</text>
+</a>
+</g>
+</g>
+<!-- ElasticsearchPersistReader->ElasticsearchPersistWriter -->
+<g id="edge2" class="edge"><title>ElasticsearchPersistReader->ElasticsearchPersistWriter</title>
+<path fill="none" stroke="black" d="M105.381,-158.762C105.381,-147.36 105.381,-132.434 105.381,-119.494"/>
+<polygon fill="black" stroke="black" points="108.881,-119.212 105.381,-109.212 101.881,-119.212 108.881,-119.212"/>
+<text text-anchor="middle" x="122.495" 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="168.188,-36 42.5743,-36 42.5743,-0 168.188,-0 168.188,-36"/>
+<text text-anchor="middle" x="105.381" y="-13.8" font-family="Times,serif" font-size="14.00">es://{index}/{type}</text>
+</g>
+<!-- ElasticsearchPersistWriter->destination -->
+<g id="edge3" class="edge"><title>ElasticsearchPersistWriter->destination</title>
+<path fill="none" stroke="black" d="M105.381,-72.9551C105.381,-64.8828 105.381,-55.1764 105.381,-46.1817"/>
+<polygon fill="black" stroke="black" points="108.881,-46.0903 105.381,-36.0904 101.881,-46.0904 108.881,-46.0903"/>
+</g>
+<!-- source -->
+<g id="node3" class="node"><title>source</title>
+<polygon fill="none" stroke="black" points="176.799,-268 33.9637,-268 33.9637,-232 176.799,-232 176.799,-268"/>
+<text text-anchor="middle" x="105.381" y="-245.8" font-family="Times,serif" font-size="14.00">es://{indexes}/{types}</text>
+</g>
+<!-- source->ElasticsearchPersistReader -->
+<g id="edge1" class="edge"><title>source->ElasticsearchPersistReader</title>
+<path fill="none" stroke="black" d="M105.381,-231.955C105.381,-223.883 105.381,-214.176 105.381,-205.182"/>
+<polygon fill="black" stroke="black" points="108.881,-205.09 105.381,-195.09 101.881,-205.09 108.881,-205.09"/>
+</g>
+</g>
+</svg>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/558ef157/local/mongo-elasticsearch-sync/src/main/resources/MongoElasticsearchSync.dot.svg
----------------------------------------------------------------------
diff --git a/local/mongo-elasticsearch-sync/src/main/resources/MongoElasticsearchSync.dot.svg b/local/mongo-elasticsearch-sync/src/main/resources/MongoElasticsearchSync.dot.svg
new file mode 100644
index 0000000..9d8de3c
--- /dev/null
+++ b/local/mongo-elasticsearch-sync/src/main/resources/MongoElasticsearchSync.dot.svg
@@ -0,0 +1,57 @@
+<?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.20150411.0445 (20150411.0445)
+ -->
+<!-- Title: g Pages: 1 -->
+<svg width="214pt" height="302pt"
+ viewBox="0.00 0.00 214.13 302.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 298)">
+<title>g</title>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-298 210.134,-298 210.134,4 -4,4"/>
+<!-- MongoPersistReader -->
+<g id="node1" class="node"><title>MongoPersistReader</title>
+<g id="a_node1"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-persist-mongo/src/main/java/org/apache/streams/mongo/MongoPersistReader.java" xlink:title="MongoPersistReader">
+<ellipse fill="none" stroke="black" cx="103.067" cy="-190" rx="84.0668" ry="18"/>
+<text text-anchor="middle" x="103.067" y="-185.8" font-family="Times,serif" font-size="14.00">MongoPersistReader</text>
+</a>
+</g>
+</g>
+<!-- ElasticsearchPersistWriter -->
+<g id="node2" class="node"><title>ElasticsearchPersistWriter</title>
+<g id="a_node2"><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="103.067" cy="-104" rx="103.134" ry="18"/>
+<text text-anchor="middle" x="103.067" y="-99.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistWriter</text>
+</a>
+</g>
+</g>
+<!-- MongoPersistReader->ElasticsearchPersistWriter -->
+<g id="edge2" class="edge"><title>MongoPersistReader->ElasticsearchPersistWriter</title>
+<path fill="none" stroke="black" d="M103.067,-171.762C103.067,-160.36 103.067,-145.434 103.067,-132.494"/>
+<polygon fill="black" stroke="black" points="106.567,-132.212 103.067,-122.212 99.5669,-132.212 106.567,-132.212"/>
+<text text-anchor="middle" x="136.888" y="-142.8" font-family="Times,serif" font-size="14.00">ObjectNode</text>
+</g>
+<!-- destination -->
+<g id="node4" class="node"><title>destination</title>
+<polygon fill="none" stroke="black" points="165.874,-36 40.2598,-36 40.2598,-0 165.874,-0 165.874,-36"/>
+<text text-anchor="middle" x="103.067" y="-13.8" font-family="Times,serif" font-size="14.00">es://{index}/{type}</text>
+</g>
+<!-- ElasticsearchPersistWriter->destination -->
+<g id="edge3" class="edge"><title>ElasticsearchPersistWriter->destination</title>
+<path fill="none" stroke="black" d="M103.067,-85.7616C103.067,-74.3597 103.067,-59.4342 103.067,-46.494"/>
+<polygon fill="black" stroke="black" points="106.567,-46.2121 103.067,-36.2121 99.5669,-46.2121 106.567,-46.2121"/>
+<text text-anchor="middle" x="136.888" y="-56.8" font-family="Times,serif" font-size="14.00">ObjectNode</text>
+</g>
+<!-- source -->
+<g id="node3" class="node"><title>source</title>
+<polygon fill="none" stroke="black" points="189.595,-294 16.5389,-294 16.5389,-258 189.595,-258 189.595,-294"/>
+<text text-anchor="middle" x="103.067" y="-271.8" font-family="Times,serif" font-size="14.00">mongdb://{db}/{collection}</text>
+</g>
+<!-- source->MongoPersistReader -->
+<g id="edge1" class="edge"><title>source->MongoPersistReader</title>
+<path fill="none" stroke="black" d="M103.067,-257.762C103.067,-246.36 103.067,-231.434 103.067,-218.494"/>
+<polygon fill="black" stroke="black" points="106.567,-218.212 103.067,-208.212 99.5669,-218.212 106.567,-218.212"/>
+<text text-anchor="middle" x="136.888" y="-228.8" font-family="Times,serif" font-size="14.00">ObjectNode</text>
+</g>
+</g>
+</svg>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/558ef157/local/twitter-follow-graph/src/main/resources/TwitterFollowGraph.dot.svg
----------------------------------------------------------------------
diff --git a/local/twitter-follow-graph/src/main/resources/TwitterFollowGraph.dot.svg b/local/twitter-follow-graph/src/main/resources/TwitterFollowGraph.dot.svg
new file mode 100644
index 0000000..dd2d233
--- /dev/null
+++ b/local/twitter-follow-graph/src/main/resources/TwitterFollowGraph.dot.svg
@@ -0,0 +1,85 @@
+<?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.20150411.0445 (20150411.0445)
+ -->
+<!-- Title: g Pages: 1 -->
+<svg width="226pt" height="375pt"
+ viewBox="0.00 0.00 225.67 375.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 371)">
+<title>g</title>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-371 221.672,-371 221.672,4 -4,4"/>
+<!-- TwitterFollowingProvider -->
+<g id="node1" class="node"><title>TwitterFollowingProvider</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/TwitterFollowingProvider.java" xlink:title="TwitterFollowingProvider">
+<ellipse fill="none" stroke="black" cx="108.836" cy="-349" rx="102.174" ry="18"/>
+<text text-anchor="middle" x="108.836" y="-344.8" font-family="Times,serif" font-size="14.00">TwitterFollowingProvider</text>
+</a>
+</g>
+</g>
+<!-- TypeConverterProcessor -->
+<g id="node2" class="node"><title>TypeConverterProcessor</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/converters/TypeConverterProcessor.java" xlink:title="TypeConverterProcessor">
+<ellipse fill="none" stroke="black" cx="108.836" cy="-263" rx="97.3117" ry="18"/>
+<text text-anchor="middle" x="108.836" y="-258.8" font-family="Times,serif" font-size="14.00">TypeConverterProcessor</text>
+</a>
+</g>
+</g>
+<!-- TwitterFollowingProvider->TypeConverterProcessor -->
+<g id="edge1" class="edge"><title>TwitterFollowingProvider->TypeConverterProcessor</title>
+<g id="a_edge1"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-provider-twitter/src/main/jsonschema/com/twitter/Follow.java" xlink:title="Follow">
+<path fill="none" stroke="black" d="M108.836,-330.762C108.836,-319.36 108.836,-304.434 108.836,-291.494"/>
+<polygon fill="black" stroke="black" points="112.336,-291.212 108.836,-281.212 105.336,-291.212 112.336,-291.212"/>
+</a>
+</g>
+<g id="a_edge1-label"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-provider-twitter/src/main/jsonschema/com/twitter/Follow.java" xlink:title="Follow">
+<text text-anchor="middle" x="128.674" y="-301.8" font-family="Times,serif" font-size="14.00">Follow</text>
+</a>
+</g>
+</g>
+<!-- ActivityConverterProcessor -->
+<g id="node3" class="node"><title>ActivityConverterProcessor</title>
+<g id="a_node3"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-components/streams-converters/src/main/java/org/apache/streams/converters/ActivityConverterProcessor.java" xlink:title="ActivityConverterProcessor">
+<ellipse fill="none" stroke="black" cx="108.836" cy="-177" rx="108.672" ry="18"/>
+<text text-anchor="middle" x="108.836" y="-172.8" font-family="Times,serif" font-size="14.00">ActivityConverterProcessor</text>
+</a>
+</g>
+</g>
+<!-- TypeConverterProcessor->ActivityConverterProcessor -->
+<g id="edge2" class="edge"><title>TypeConverterProcessor->ActivityConverterProcessor</title>
+<path fill="none" stroke="black" d="M108.836,-244.762C108.836,-233.36 108.836,-218.434 108.836,-205.494"/>
+<polygon fill="black" stroke="black" points="112.336,-205.212 108.836,-195.212 105.336,-205.212 112.336,-205.212"/>
+<text text-anchor="middle" x="125.95" y="-215.8" font-family="Times,serif" font-size="14.00">String</text>
+</g>
+<!-- GraphPersistWriter -->
+<g id="node4" class="node"><title>GraphPersistWriter</title>
+<g id="a_node4"><a xlink:href="https://github.com/apache/incubator-streams/blob/master/streams-contrib/streams-persist-graph/src/main/java/org/apache/streams/graph/GraphPersistWriter.java" xlink:title="GraphPersistWriter">
+<ellipse fill="none" stroke="black" cx="108.836" cy="-91" rx="78.5369" ry="18"/>
+<text text-anchor="middle" x="108.836" y="-86.8" font-family="Times,serif" font-size="14.00">GraphPersistWriter</text>
+</a>
+</g>
+</g>
+<!-- ActivityConverterProcessor->GraphPersistWriter -->
+<g id="edge3" class="edge"><title>ActivityConverterProcessor->GraphPersistWriter</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="M108.836,-158.762C108.836,-147.36 108.836,-132.434 108.836,-119.494"/>
+<polygon fill="black" stroke="black" points="112.336,-119.212 108.836,-109.212 105.336,-119.212 112.336,-119.212"/>
+</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="131.777" y="-129.8" font-family="Times,serif" font-size="14.00">Activity</text>
+</a>
+</g>
+</g>
+<!-- destination -->
+<g id="node5" class="node"><title>destination</title>
+<polygon fill="none" stroke="black" points="194.539,-36 23.1326,-36 23.1326,-0 194.539,-0 194.539,-36"/>
+<text text-anchor="middle" x="108.836" y="-13.8" font-family="Times,serif" font-size="14.00">http://{host}:{port}/db/data</text>
+</g>
+<!-- GraphPersistWriter->destination -->
+<g id="edge4" class="edge"><title>GraphPersistWriter->destination</title>
+<path fill="none" stroke="black" d="M108.836,-72.9551C108.836,-64.8828 108.836,-55.1764 108.836,-46.1817"/>
+<polygon fill="black" stroke="black" points="112.336,-46.0903 108.836,-36.0904 105.336,-46.0904 112.336,-46.0903"/>
+</g>
+</g>
+</svg>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/558ef157/local/twitter-history-elasticsearch/src/main/resources/TwitterHistoryElasticsearch.dot.svg
----------------------------------------------------------------------
diff --git a/local/twitter-history-elasticsearch/src/main/resources/TwitterHistoryElasticsearch.dot.svg b/local/twitter-history-elasticsearch/src/main/resources/TwitterHistoryElasticsearch.dot.svg
new file mode 100644
index 0000000..eed4633
--- /dev/null
+++ b/local/twitter-history-elasticsearch/src/main/resources/TwitterHistoryElasticsearch.dot.svg
@@ -0,0 +1,72 @@
+<?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.20150411.0445 (20150411.0445)
+ -->
+<!-- Title: g Pages: 1 -->
+<svg width="214pt" height="302pt"
+ viewBox="0.00 0.00 214.13 302.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 298)">
+<title>g</title>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-298 210.134,-298 210.134,4 -4,4"/>
+<!-- TwitterTimelineProvider -->
+<g id="node1" class="node"><title>TwitterTimelineProvider</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/TwitterTimelineProvider.java" xlink:title="TwitterTimelineProvider">
+<ellipse fill="none" stroke="black" cx="103.067" cy="-276" rx="97.6831" ry="18"/>
+<text text-anchor="middle" x="103.067" y="-271.8" font-family="Times,serif" font-size="14.00">TwitterTimelineProvider</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="189.364,-208 16.7697,-208 16.7697,-172 189.364,-172 189.364,-208"/>
+<text text-anchor="middle" x="103.067" y="-185.8" font-family="Times,serif" font-size="14.00">ActivityConverterProcessor</text>
+</a>
+</g>
+</g>
+<!-- TwitterTimelineProvider->ActivityConverterProcessor -->
+<g id="edge1" class="edge"><title>TwitterTimelineProvider->ActivityConverterProcessor</title>
+<path fill="none" stroke="black" d="M103.067,-257.762C103.067,-246.36 103.067,-231.434 103.067,-218.494"/>
+<polygon fill="black" stroke="black" points="106.567,-218.212 103.067,-208.212 99.5669,-218.212 106.567,-218.212"/>
+<text text-anchor="middle" x="136.888" y="-228.8" font-family="Times,serif" font-size="14.00">ObjectNode</text>
+</g>
+<!-- ElasticsearchPersistWriter -->
+<g id="node3" class="node"><title>ElasticsearchPersistWriter</title>
+<g id="a_node3"><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="103.067" cy="-104" rx="103.134" ry="18"/>
+<text text-anchor="middle" x="103.067" y="-99.8" font-family="Times,serif" font-size="14.00">ElasticsearchPersistWriter</text>
+</a>
+</g>
+</g>
+<!-- ActivityConverterProcessor->ElasticsearchPersistWriter -->
+<g id="edge2" class="edge"><title>ActivityConverterProcessor->ElasticsearchPersistWriter</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="M103.067,-171.762C103.067,-160.36 103.067,-145.434 103.067,-132.494"/>
+<polygon fill="black" stroke="black" points="106.567,-132.212 103.067,-122.212 99.5669,-132.212 106.567,-132.212"/>
+</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="126.008" y="-142.8" font-family="Times,serif" font-size="14.00">Activity</text>
+</a>
+</g>
+</g>
+<!-- es -->
+<g id="node4" class="node"><title>es</title>
+<polygon fill="none" stroke="black" points="165.874,-36 40.2598,-36 40.2598,-0 165.874,-0 165.874,-36"/>
+<text text-anchor="middle" x="103.067" y="-13.8" font-family="Times,serif" font-size="14.00">es://{index}/{type}</text>
+</g>
+<!-- ElasticsearchPersistWriter->es -->
+<g id="edge3" class="edge"><title>ElasticsearchPersistWriter->es</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="M103.067,-85.7616C103.067,-74.3597 103.067,-59.4342 103.067,-46.494"/>
+<polygon fill="black" stroke="black" points="106.567,-46.2121 103.067,-36.2121 99.5669,-46.2121 106.567,-46.2121"/>
+</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="126.008" y="-56.8" font-family="Times,serif" font-size="14.00">Activity</text>
+</a>
+</g>
+</g>
+</g>
+</svg>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/558ef157/local/twitter-userstream-elasticsearch/src/main/resources/TwitterUserstreamElasticsearch.dot.svg
----------------------------------------------------------------------
diff --git a/local/twitter-userstream-elasticsearch/src/main/resources/TwitterUserstreamElasticsearch.dot.svg b/local/twitter-userstream-elasticsearch/src/main/resources/TwitterUserstreamElasticsearch.dot.svg
new file mode 100644
index 0000000..48464f6
--- /dev/null
+++ b/local/twitter-userstream-elasticsearch/src/main/resources/TwitterUserstreamElasticsearch.dot.svg
@@ -0,0 +1,164 @@
+<?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.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>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/558ef157/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 2c39199..976d880 100644
--- a/pom.xml
+++ b/pom.xml
@@ -322,8 +322,10 @@
</configuration>
</plugin>
<plugin>
+ <artifactId>maven-resources-plugin</artifactId>
+ </plugin>
+ <plugin>
<artifactId>maven-site-plugin</artifactId>
- <version>${site.plugin.version}</version>
</plugin>
</plugins>
<pluginManagement>
@@ -473,7 +475,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-site-plugin</artifactId>
- <version>3.4</version>
+ <version>${site.plugin.version}</version>
<dependencies>
<dependency>
<groupId>org.apache.maven.wagon</groupId>