This is an automated email from the ASF dual-hosted git repository.
kennethmcfarland pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/fluo-website.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 6fbc8ec Jekyll build from gh-pages:755ecf0
6fbc8ec is described below
commit 6fbc8ec018dec14623d94ab97cb3bf3357a9f24d
Author: Kenneth McFarland <[email protected]>
AuthorDate: Fri Dec 22 10:43:37 2017 -0800
Jekyll build from gh-pages:755ecf0
Merge pull request #115 from mikewalch/docs-update
Updated documentation for 1.2 changes
---
.../1.2/getting-started/create-application.html | 19 ++++++++++---------
feed.xml | 4 ++--
resources/docs/fluo-architecture.odg | Bin 16670 -> 16603 bytes
resources/docs/fluo-architecture.png | Bin 61085 -> 64127 bytes
4 files changed, 12 insertions(+), 11 deletions(-)
diff --git a/docs/fluo/1.2/getting-started/create-application.html
b/docs/fluo/1.2/getting-started/create-application.html
index 2c26b88..1903134 100644
--- a/docs/fluo/1.2/getting-started/create-application.html
+++ b/docs/fluo/1.2/getting-started/create-application.html
@@ -273,9 +273,8 @@ create a <a
href="https://static.javadoc.io/org.apache.fluo/fluo-api/1.1.0-incub
<ol>
<li>
- <p>Create one or more classes that extend <a
href="https://static.javadoc.io/org.apache.fluo/fluo-api/1.1.0-incubating/org/apache/fluo/api/observer/Observer.html";>Observer</a>
like the example below. Please use <a href="http://www.slf4j.org/";>slf4j</a>
for
-any logging in observers as <a href="http://www.slf4j.org/";>slf4j</a> supports
multiple logging implementations. This is
-necessary as Fluo applications have a hard requirement on <a
href="http://logback.qos.ch/";>logback</a> when running in YARN.</p>
+ <p>Create one or more classes that extend <a
href="https://static.javadoc.io/org.apache.fluo/fluo-api/1.1.0-incubating/org/apache/fluo/api/observer/Observer.html";>Observer</a>
like the example below. It is a good idea to
+use <a href="http://www.slf4j.org/";>slf4j</a> for any logging in observers as
<a href="http://www.slf4j.org/";>slf4j</a> supports multiple logging
implementations.</p>
<div class="language-java highlighter-rouge"><pre
class="highlight"><code><span class="kd">public</span> <span
class="kd">class</span> <span class="nc">InvertObserver</span> <span
class="kd">implements</span> <span class="n">Observer</span> <span
class="o">{</span>
@@ -297,13 +296,13 @@ register multiple observers.</p>
<div class="language-java highlighter-rouge"><pre
class="highlight"><code><span class="kd">class</span> <span
class="nc">AppObserverProvider</span> <span class="kd">implements</span> <span
class="n">ObserverProvider</span> <span class="o">{</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span
class="nf">provide</span><span class="o">(</span><span
class="n">Registry</span> <span class="n">or</span><span class="o">,</span>
<span class="n">Context</span> <span class="n">ctx</span><span
class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span
class="nf">provide</span><span class="o">(</span><span
class="n">Registry</span> <span class="n">reg</span><span class="o">,</span>
<span class="n">Context</span> <span class="n">ctx</span><span
class="o">)</span> <span class="o">{</span>
<span class="c1">//setup InvertObserver to be triggered when the column
obs:data is modified</span>
- <span class="n">or</span><span class="o">.</span><span
class="na">forColumn</span><span class="o">(</span><span class="k">new</span>
<span class="n">Column</span><span class="o">(</span><span
class="s">"obs"</span><span class="o">,</span> <span
class="s">"data"</span><span class="o">),</span> <span
class="n">NotificationType</span><span class="o">.</span><span
class="na">STRONG</span><span class="o">)</span>
+ <span class="n">reg</span><span class="o">.</span><span
class="na">forColumn</span><span class="o">(</span><span class="k">new</span>
<span class="n">Column</span><span class="o">(</span><span
class="s">"obs"</span><span class="o">,</span> <span
class="s">"data"</span><span class="o">),</span> <span
class="n">NotificationType</span><span class="o">.</span><span
class="na">STRONG</span><span class="o">)</span>
<span class="o">.</span><span class="na">useObserver</span><span
class="o">(</span><span class="k">new</span> <span
class="n">InvertObserver</span><span class="o">());</span>
<span class="c1">//Observer is a Functional interface. So Observers can
be written as lambdas.</span>
- <span class="n">or</span><span class="o">.</span><span
class="na">forColumn</span><span class="o">(</span><span class="k">new</span>
<span class="n">Column</span><span class="o">(</span><span
class="s">"new"</span><span class="o">,</span><span
class="s">"data"</span><span class="o">),</span> <span
class="n">NotificationType</span><span class="o">.</span><span
class="na">WEAK</span><span class="o">)</span>
+ <span class="n">reg</span><span class="o">.</span><span
class="na">forColumn</span><span class="o">(</span><span class="k">new</span>
<span class="n">Column</span><span class="o">(</span><span
class="s">"new"</span><span class="o">,</span><span
class="s">"data"</span><span class="o">),</span> <span
class="n">NotificationType</span><span class="o">.</span><span
class="na">WEAK</span><span class="o">)</span>
<span class="o">.</span><span class="na">useObserver</span><span
class="o">((</span><span class="n">tx</span><span class="o">,</span><span
class="n">row</span><span class="o">,</span><span class="n">col</span><span
class="o">)</span> <span class="o">-></span> <span class="o">{</span>
<span class="n">Bytes</span> <span class="n">combined</span> <span
class="o">=</span> <span class="n">combineNewAndOld</span><span
class="o">(</span><span class="n">tx</span><span class="o">,</span><span
class="n">row</span><span class="o">);</span>
<span class="n">tx</span><span class="o">.</span><span
class="na">set</span><span class="o">(</span><span class="n">row</span><span
class="o">,</span> <span class="k">new</span> <span
class="n">Column</span><span class="o">(</span><span
class="s">"current"</span><span class="o">,</span><span
class="s">"data"</span><span class="o">),</span> <span
class="n">combined</span><span class="o">);</span>
@@ -313,9 +312,11 @@ register multiple observers.</p>
</code></pre>
</div>
</li>
- <li>Build a jar containing these classes and include this jar in the <code
class="highlighter-rouge">lib/</code> directory of your Fluo
-application.</li>
- <li>Configure your Fluo application to use this observer provider by
modifying the Application section of
+ <li>Build a jar containing these classes. Put this jar and any other
dependencies required for your
+application in a directory. Set <code
class="highlighter-rouge">fluo.observer.init.dir</code> in <a
href="https://github.com/apache/fluo/blob/master/modules/distribution/src/main/config/fluo-app.properties";>fluo-app.properties</a>
to the path of
+this directory. When your application is initialized, these jars will be
loaded to HDFS to make
+them accessible to all of your Fluo workers on the cluster.</li>
+ <li>Configure your Fluo application to use your observer provider by
modifying the Application section of
<a
href="https://github.com/apache/fluo/blob/master/modules/distribution/src/main/config/fluo-app.properties";>fluo-app.properties</a>.
Set <code class="highlighter-rouge">fluo.observer.provider</code> to the
observer provider class name.</li>
<li>Initialize your Fluo application as described in the next section.
During initialization Fluo
will obtain the observed columns from the ObserverProvider and persist the
columns in Zookeeper.
diff --git a/feed.xml b/feed.xml
index d5b5c26..653c925 100644
--- a/feed.xml
+++ b/feed.xml
@@ -5,8 +5,8 @@
<description></description>
<link>https://fluo.apache.org//</link>
<atom:link href="https://fluo.apache.org//feed.xml"; rel="self"
type="application/rss+xml" />
- <pubDate>Thu, 21 Dec 2017 13:31:05 +0000</pubDate>
- <lastBuildDate>Thu, 21 Dec 2017 13:31:05 +0000</lastBuildDate>
+ <pubDate>Fri, 22 Dec 2017 18:43:31 +0000</pubDate>
+ <lastBuildDate>Fri, 22 Dec 2017 18:43:31 +0000</lastBuildDate>
<generator>Jekyll v3.3.1</generator>
diff --git a/resources/docs/fluo-architecture.odg
b/resources/docs/fluo-architecture.odg
index fb2a9ad..0cc7bf9 100644
Binary files a/resources/docs/fluo-architecture.odg and
b/resources/docs/fluo-architecture.odg differ
diff --git a/resources/docs/fluo-architecture.png
b/resources/docs/fluo-architecture.png
index 3ba96fd..b1b2cf4 100644
Binary files a/resources/docs/fluo-architecture.png and
b/resources/docs/fluo-architecture.png differ
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
