You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluo.apache.org by mw...@apache.org on 2016/08/02 15:46:29 UTC
[3/4] incubator-fluo-website git commit: Jekyll build from
gh-pages:6ec27f6
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-1/export-queue/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-1/export-queue/index.html b/docs/fluo-recipes/1.0.0-beta-1/export-queue/index.html
index 6e5ad40..ec68a70 100644
--- a/docs/fluo-recipes/1.0.0-beta-1/export-queue/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-1/export-queue/index.html
@@ -76,6 +76,10 @@
<div class="alert alert-danger" role="alert">These docs are for Fluo Recipes 1.0.0-beta-1 which is an old version! Check out the <a href="/docs/fluo-recipes/1.0.0-beta-2">latest docs</a>!</div>
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Export Queue Recipe</h2>
</header>
@@ -104,7 +108,7 @@ like Redis, Elasticsearch, MySQL, etc.</p>
To understand what can go wrong consider the following example observer
transaction.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
<span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">TYPEL</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TypeLayer</span><span class="o">(</span><span class="k">new</span> <span class="n">StringEncoder</span><span class="o">());</span>
@@ -112,7 +116,7 @@ transaction.</p>
<span class="n">QuerySystem</span> <span class="n">querySystem</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
<span class="n">TypedTransactionBase</span> <span class="n">ttx</span> <span class="o">=</span> <span class="n">TYPEL</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
<span class="kt">int</span> <span class="n">oldCount</span> <span class="o">=</span> <span class="n">ttx</span><span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">row</span><span class="o">(</span><span class="n">row</span><span class="o">).</span><span class="na">fam</span><span class="o">(</span><span class="s">"meta"</span><span class="o">).</span><span class="na">qual</span><span class="o">(</span><span class="s">"counter1"</span><span class="o">).</span><span class="na">toInteger</span><span class="o">(</span><span class="mi">0</span><span class="o">);</span>
@@ -202,11 +206,11 @@ optimization process</a>.</p>
query system using an export queue. The class below is simple POJO to hold the
count update, this will be used as the value for the export queue.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kd">class</span> <span class="nc">CountUpdate</span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">class</span> <span class="nc">CountUpdate</span> <span class="o">{</span>
<span class="kd">public</span> <span class="kt">int</span> <span class="n">oldCount</span><span class="o">;</span>
<span class="kd">public</span> <span class="kt">int</span> <span class="n">newCount</span><span class="o">;</span>
- <span class="kd">public</span> <span class="n">CountUpdate</span><span class="o">(</span><span class="kt">int</span> <span class="n">oc</span><span class="o">,</span> <span class="kt">int</span> <span class="n">nc</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="nf">CountUpdate</span><span class="o">(</span><span class="kt">int</span> <span class="n">oc</span><span class="o">,</span> <span class="kt">int</span> <span class="n">nc</span><span class="o">)</span> <span class="o">{</span>
<span class="k">this</span><span class="o">.</span><span class="na">oldCount</span> <span class="o">=</span> <span class="n">oc</span><span class="o">;</span>
<span class="k">this</span><span class="o">.</span><span class="na">newCount</span> <span class="o">=</span> <span class="n">nc</span><span class="o">;</span>
<span class="o">}</span>
@@ -219,7 +223,7 @@ modify the FluoConfiguration object with options needed for the export queue.
This FluoConfiguration object should be used to initialize the fluo
application.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="c1">//queue id "ici" means inverted count index, would probably use static final in real application</span>
<span class="n">String</span> <span class="n">exportQueueID</span> <span class="o">=</span> <span class="s">"ici"</span><span class="o">;</span>
@@ -239,19 +243,19 @@ application.</p>
<p>Below is updated version of the observer from above thats now using the export
queue.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
<span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">TYPEL</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TypeLayer</span><span class="o">(</span><span class="k">new</span> <span class="n">StringEncoder</span><span class="o">());</span>
<span class="kd">private</span> <span class="n">ExportQueue</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">></span> <span class="n">exportQueue</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">init</span><span class="o">(</span><span class="n">Context</span> <span class="n">context</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">init</span><span class="o">(</span><span class="n">Context</span> <span class="n">context</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
<span class="n">exportQueue</span> <span class="o">=</span> <span class="n">ExportQueue</span><span class="o">.</span><span class="na">getInstance</span><span class="o">(</span><span class="s">"ici"</span><span class="o">,</span> <span class="n">context</span><span class="o">.</span><span class="na">getAppConfiguration</span><span class="o">());</span>
<span class="o">}</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
<span class="n">TypedTransactionBase</span> <span class="n">ttx</span> <span class="o">=</span> <span class="n">TYPEL</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
<span class="kt">int</span> <span class="n">oldCount</span> <span class="o">=</span> <span class="n">ttx</span><span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">row</span><span class="o">(</span><span class="n">row</span><span class="o">).</span><span class="na">fam</span><span class="o">(</span><span class="s">"meta"</span><span class="o">).</span><span class="na">qual</span><span class="o">(</span><span class="s">"counter1"</span><span class="o">).</span><span class="na">toInteger</span><span class="o">(</span><span class="mi">0</span><span class="o">);</span>
@@ -280,12 +284,12 @@ arriving out of order and multiple times. The purpose of the sequence number
is to help systems receiving data from Fluo process out of order and redundant
data.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="kd">public</span> <span class="kd">class</span> <span class="nc">CountExporter</span> <span class="kd">extends</span> <span class="n">Exporter</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">></span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="kd">public</span> <span class="kd">class</span> <span class="nc">CountExporter</span> <span class="kd">extends</span> <span class="n">Exporter</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">></span> <span class="o">{</span>
<span class="c1">//represents the external query system we want to update from Fluo</span>
<span class="n">QuerySystem</span> <span class="n">querySystem</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">protected</span> <span class="kt">void</span> <span class="n">processExports</span><span class="o">(</span><span class="n">Iterator</span><span class="o"><</span><span class="n">SequencedExport</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">>></span> <span class="n">exportIterator</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">protected</span> <span class="kt">void</span> <span class="nf">processExports</span><span class="o">(</span><span class="n">Iterator</span><span class="o"><</span><span class="n">SequencedExport</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">>></span> <span class="n">exportIterator</span><span class="o">)</span> <span class="o">{</span>
<span class="n">BatchUpdater</span> <span class="n">batchUpdater</span> <span class="o">=</span> <span class="n">querySystem</span><span class="o">.</span><span class="na">getBatchUpdater</span><span class="o">();</span>
<span class="k">while</span><span class="o">(</span><span class="n">exportIterator</span><span class="o">.</span><span class="na">hasNext</span><span class="o">()){</span>
<span class="n">SequencedExport</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">></span> <span class="n">exportEntry</span> <span class="o">=</span> <span class="n">exportItertor</span><span class="o">.</span><span class="na">next</span><span class="o">();</span>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-1/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-1/index.html b/docs/fluo-recipes/1.0.0-beta-1/index.html
index 9d2ce1c..caa9cbb 100644
--- a/docs/fluo-recipes/1.0.0-beta-1/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-1/index.html
@@ -76,6 +76,10 @@
<div class="alert alert-danger" role="alert">These docs are for Fluo Recipes 1.0.0-beta-1 which is an old version! Check out the <a href="/docs/fluo-recipes/1.0.0-beta-2">latest docs</a>!</div>
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Fluo Recipes 1.0.0-beta-1 Documentation</h2>
</header>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-1/recording-tx/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-1/recording-tx/index.html b/docs/fluo-recipes/1.0.0-beta-1/recording-tx/index.html
index fcd781e..97c8f17 100644
--- a/docs/fluo-recipes/1.0.0-beta-1/recording-tx/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-1/recording-tx/index.html
@@ -76,6 +76,10 @@
<div class="alert alert-danger" role="alert">These docs are for Fluo Recipes 1.0.0-beta-1 which is an old version! Check out the <a href="/docs/fluo-recipes/1.0.0-beta-2">latest docs</a>!</div>
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">RecordingTransaction recipe</h2>
</header>
@@ -85,21 +89,21 @@
(i.e GET, SET, or DELETE) to a <code class="highlighter-rouge">TxLog</code> object for later uses such as exporting data. The code below
shows how a RecordingTransaction is created by wrapping a Transaction object:</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
</code></pre>
</div>
<p>A predicate function can be passed to wrap method to select which log entries to record. The code
below only records log entries whose column family is <code class="highlighter-rouge">meta</code>:</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">,</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">,</span>
<span class="n">le</span> <span class="o">-></span> <span class="n">le</span><span class="o">.</span><span class="na">getColumn</span><span class="o">().</span><span class="na">getFamily</span><span class="o">().</span><span class="na">toString</span><span class="o">().</span><span class="na">equals</span><span class="o">(</span><span class="s">"meta"</span><span class="o">));</span>
</code></pre>
</div>
<p>After creating a RecordingTransaction, users can use it as they would use a Transaction object.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">Bytes</span> <span class="n">value</span> <span class="o">=</span> <span class="n">rtx</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">Bytes</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="s">"r1"</span><span class="o">),</span> <span class="k">new</span> <span class="n">Column</span><span class="o">(</span><span class="s">"cf1"</span><span class="o">,</span> <span class="s">"cq1"</span><span class="o">));</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">Bytes</span> <span class="n">value</span> <span class="o">=</span> <span class="n">rtx</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">Bytes</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="s">"r1"</span><span class="o">),</span> <span class="k">new</span> <span class="n">Column</span><span class="o">(</span><span class="s">"cf1"</span><span class="o">,</span> <span class="s">"cq1"</span><span class="o">));</span>
</code></pre>
</div>
@@ -110,7 +114,7 @@ necessary if you want to determine the changes made by the transaction.</p>
<p>When you are done operating on the transaction, you can retrieve the TxLog using the following code:</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">TxLog</span> <span class="n">myTxLog</span> <span class="o">=</span> <span class="n">rtx</span><span class="o">.</span><span class="na">getTxLog</span><span class="o">()</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">TxLog</span> <span class="n">myTxLog</span> <span class="o">=</span> <span class="n">rtx</span><span class="o">.</span><span class="na">getTxLog</span><span class="o">()</span>
</code></pre>
</div>
@@ -119,14 +123,14 @@ performed by the transaction in a TxLog. In this example, a GET (if data exists
will be logged. This TxLog can be added to an export queue and later used to export updates from
Fluo.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
<span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">TYPEL</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TypeLayer</span><span class="o">(</span><span class="k">new</span> <span class="n">StringEncoder</span><span class="o">());</span>
<span class="kd">private</span> <span class="n">ExportQueue</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">TxLog</span><span class="o">></span> <span class="n">exportQueue</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
<span class="c1">// create recording transaction (rtx)</span>
<span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-1/serialization/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-1/serialization/index.html b/docs/fluo-recipes/1.0.0-beta-1/serialization/index.html
index b3baf8e..3b5e39d 100644
--- a/docs/fluo-recipes/1.0.0-beta-1/serialization/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-1/serialization/index.html
@@ -76,6 +76,10 @@
<div class="alert alert-danger" role="alert">These docs are for Fluo Recipes 1.0.0-beta-1 which is an old version! Check out the <a href="/docs/fluo-recipes/1.0.0-beta-2">latest docs</a>!</div>
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Serializing Data</h2>
</header>
@@ -91,7 +95,7 @@ first step is to implement <a href="/apidocs/fluo-recipes/1.0.0-beta-1/io/fluo/r
configure Fluo Recipes to use the custom implementation. This needs to be done
before initializing Fluo. Below is an example of how to do this.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="c1">//assume MySerializer implements SimpleSerializer</span>
<span class="n">SimpleSerializer</span><span class="o">.</span><span class="na">setSetserlializer</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">,</span> <span class="n">MySerializer</span><span class="o">.</span><span class="na">class</span><span class="o">);</span>
<span class="c1">//initialize Fluo using fluoConfig</span>
@@ -112,7 +116,7 @@ example below shows how to do this.</p>
need to be registered with Kryo. This could be done by creating a KryoFactory
like the following.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code>
<span class="kn">package</span> <span class="n">com</span><span class="o">.</span><span class="na">foo</span><span class="o">;</span>
<span class="kn">import</span> <span class="nn">com.esotericsoftware.kryo.Kryo</span><span class="o">;</span>
@@ -123,7 +127,7 @@ like the following.</p>
<span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyKryoFactory</span> <span class="kd">implements</span> <span class="n">KryoFactory</span> <span class="o">{</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">Kryo</span> <span class="n">create</span><span class="o">()</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="n">Kryo</span> <span class="nf">create</span><span class="o">()</span> <span class="o">{</span>
<span class="n">Kryo</span> <span class="n">kryo</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Kryo</span><span class="o">();</span>
<span class="c1">//Explicitly assign each class a unique id here to ensure its stable over</span>
@@ -143,7 +147,7 @@ like the following.</p>
<p>Fluo Recipes must be configured to use this factory. The following code shows
how to do this.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="n">KryoSimplerSerializer</span><span class="o">.</span><span class="na">setKryoFactory</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">,</span> <span class="n">MyKryoFactory</span><span class="o">.</span><span class="na">class</span><span class="o">);</span>
<span class="c1">//initialize Fluo using fluoConfig</span>
</code></pre>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-1/table-optimization/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-1/table-optimization/index.html b/docs/fluo-recipes/1.0.0-beta-1/table-optimization/index.html
index 75c11d4..6e6c0d4 100644
--- a/docs/fluo-recipes/1.0.0-beta-1/table-optimization/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-1/table-optimization/index.html
@@ -76,6 +76,10 @@
<div class="alert alert-danger" role="alert">These docs are for Fluo Recipes 1.0.0-beta-1 which is an old version! Check out the <a href="/docs/fluo-recipes/1.0.0-beta-2">latest docs</a>!</div>
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Fluo Table Optimization</h2>
</header>
@@ -92,7 +96,7 @@ want to use them in production.</p>
<h2 id="java-example">Java Example</h2>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConf</span> <span class="o">=</span> <span class="o">...</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConf</span> <span class="o">=</span> <span class="o">...</span>
<span class="c1">//export queue configure method will return table optimizations it would like made</span>
<span class="n">ExportQueue</span><span class="o">.</span><span class="na">configure</span><span class="o">(</span><span class="n">fluoConf</span><span class="o">,</span> <span class="o">...);</span>
@@ -123,7 +127,7 @@ selective optimizations is need look into using the following methods instead.</
recipes from the command line. This should be done after configuring reciped
and initializing Fluo. Below are example command for initializing in this way.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code>
+<div class="language-bash highlighter-rouge"><pre class="highlight"><code>
<span class="c">#create application </span>
fluo new app1
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-1/transient/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-1/transient/index.html b/docs/fluo-recipes/1.0.0-beta-1/transient/index.html
index 10daf42..6f50339 100644
--- a/docs/fluo-recipes/1.0.0-beta-1/transient/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-1/transient/index.html
@@ -76,6 +76,10 @@
<div class="alert alert-danger" role="alert">These docs are for Fluo Recipes 1.0.0-beta-1 which is an old version! Check out the <a href="/docs/fluo-recipes/1.0.0-beta-2">latest docs</a>!</div>
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Transient data</h2>
</header>
@@ -108,7 +112,7 @@ transient ranges when configured. If you would like to register your own
transient ranges, use <a href="/apidocs/fluo-recipes/1.0.0-beta-1/io/fluo/recipes/common/TransientRegistry.html">TransientRegistry</a>. Below is a simple example of
using this.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="n">TransientRegistry</span> <span class="n">transientRegistry</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TransientRegistry</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">.</span><span class="na">getAppConfiguration</span><span class="o">());</span>
<span class="n">transientRegistry</span><span class="o">.</span><span class="na">addTransientRange</span><span class="o">(</span><span class="k">new</span> <span class="n">RowRange</span><span class="o">(</span><span class="n">startRow</span><span class="o">,</span> <span class="n">endRow</span><span class="o">));</span>
@@ -124,7 +128,7 @@ need to periodically compact transient ranges if using a recipe that registers
them. Using <a href="/apidocs/fluo-recipes/1.0.0-beta-1/io/fluo/recipes/accumulo/ops/TableOperations.html">TableOperations</a> this can be done with one line of Java code
like the following.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="n">TableOperations</span><span class="o">.</span><span class="na">compactTransient</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">);</span>
</code></pre>
</div>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/accumulo-export/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/accumulo-export/index.html b/docs/fluo-recipes/1.0.0-beta-2/accumulo-export/index.html
index fc70879..46de00c 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/accumulo-export/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/accumulo-export/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Accumulo Export Queue Specialization</h2>
</header>
@@ -105,7 +109,7 @@ for Accumulo is provided in the Fluo Recipes Accumulo module.</p>
<p>The following code shows how to configure an Export Queue that will write to an
external Accumulo table.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code>
<span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="c1">//Configure an export queue to use the classes Fluo Recipes provides for</span>
@@ -122,7 +126,7 @@ external Accumulo table.</p>
<span class="c1">//Configure the Accumulo table to export to.</span>
<span class="n">AccumuloExporter</span><span class="o">.</span><span class="na">setExportTableInfo</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">,</span> <span class="n">EXPORT_QUEUE_ID</span><span class="o">,</span>
- <span class="k">new</span> <span class="n">TableInfo</span><span class="o">(</span><span class="n">instance</span><span class="o">,</span> <span class="n">zookeepers</span><span class="o">,</span> <span class="n">user</span><span class="o">,</span> <span class="n">password</span><span class="o">,</span> <span class="n">exportTable</span><span class="o">));</span>
+ <span class="k">new</span> <span class="nf">TableInfo</span><span class="o">(</span><span class="n">instance</span><span class="o">,</span> <span class="n">zookeepers</span><span class="o">,</span> <span class="n">user</span><span class="o">,</span> <span class="n">password</span><span class="o">,</span> <span class="n">exportTable</span><span class="o">));</span>
<span class="c1">//initialize Fluo using fluoConfig</span>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/cfm/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/cfm/index.html b/docs/fluo-recipes/1.0.0-beta-2/cfm/index.html
index 54e6fbe..1e822a8 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/cfm/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/cfm/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Collision Free Map Recipe</h2>
</header>
@@ -146,7 +150,7 @@ Collision Free Map.</p>
<p>The following snippet shows how to setup a collision free map.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="kt">int</span> <span class="n">numBuckets</span> <span class="o">=</span> <span class="mi">119</span><span class="o">;</span>
@@ -161,22 +165,22 @@ Collision Free Map.</p>
updated. It examines new and old document content and determines changes in
word counts. These changes are pushed to a collision free map.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">DocumentObserver</span> <span class="kd">extends</span> <span class="n">TypedObserver</span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">DocumentObserver</span> <span class="kd">extends</span> <span class="n">TypedObserver</span> <span class="o">{</span>
<span class="n">CollisionFreeMap</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="n">wcm</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">init</span><span class="o">(</span><span class="n">Context</span> <span class="n">context</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">init</span><span class="o">(</span><span class="n">Context</span> <span class="n">context</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
<span class="n">wcm</span> <span class="o">=</span> <span class="n">CollisionFreeMap</span><span class="o">.</span><span class="na">getInstance</span><span class="o">(</span><span class="n">WordCountMap</span><span class="o">.</span><span class="na">ID</span><span class="o">,</span> <span class="n">context</span><span class="o">.</span><span class="na">getAppConfiguration</span><span class="o">());</span>
<span class="o">}</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">ObservedColumn</span> <span class="n">getObservedColumn</span><span class="o">()</span> <span class="o">{</span>
- <span class="k">return</span> <span class="k">new</span> <span class="n">ObservedColumn</span><span class="o">(</span><span class="k">new</span> <span class="n">Column</span><span class="o">(</span><span class="s">"content"</span><span class="o">,</span> <span class="s">"new"</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="kd">public</span> <span class="n">ObservedColumn</span> <span class="nf">getObservedColumn</span><span class="o">()</span> <span class="o">{</span>
+ <span class="k">return</span> <span class="k">new</span> <span class="nf">ObservedColumn</span><span class="o">(</span><span class="k">new</span> <span class="n">Column</span><span class="o">(</span><span class="s">"content"</span><span class="o">,</span> <span class="s">"new"</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="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">process</span><span class="o">(</span><span class="n">TypedTransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">process</span><span class="o">(</span><span class="n">TypedTransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
<span class="n">String</span> <span class="n">newContent</span> <span class="o">=</span> <span class="n">tx</span><span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">row</span><span class="o">(</span><span class="n">row</span><span class="o">).</span><span class="na">col</span><span class="o">(</span><span class="n">col</span><span class="o">).</span><span class="na">toString</span><span class="o">();</span>
<span class="n">String</span> <span class="n">currentContent</span> <span class="o">=</span> <span class="n">tx</span><span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">row</span><span class="o">(</span><span class="n">row</span><span class="o">).</span><span class="na">fam</span><span class="o">(</span><span class="s">"content"</span><span class="o">).</span><span class="na">qual</span><span class="o">(</span><span class="s">"current"</span><span class="o">).</span><span class="na">toString</span><span class="o">(</span><span class="s">""</span><span class="o">);</span>
@@ -194,11 +198,11 @@ word counts. These changes are pushed to a collision free map.</p>
<span class="n">tx</span><span class="o">.</span><span class="na">mutate</span><span class="o">().</span><span class="na">row</span><span class="o">(</span><span class="n">row</span><span class="o">).</span><span class="na">col</span><span class="o">(</span><span class="n">col</span><span class="o">).</span><span class="na">delete</span><span class="o">();</span>
<span class="o">}</span>
- <span class="kd">private</span> <span class="kd">static</span> <span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="n">getWordCounts</span><span class="o">(</span><span class="n">String</span> <span class="n">doc</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">private</span> <span class="kd">static</span> <span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="nf">getWordCounts</span><span class="o">(</span><span class="n">String</span> <span class="n">doc</span><span class="o">)</span> <span class="o">{</span>
<span class="c1">//TODO extract words from doc</span>
<span class="o">}</span>
- <span class="kd">private</span> <span class="kd">static</span> <span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="n">calculateChanges</span><span class="o">(</span><span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="n">newCounts</span><span class="o">,</span>
+ <span class="kd">private</span> <span class="kd">static</span> <span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="nf">calculateChanges</span><span class="o">(</span><span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="n">newCounts</span><span class="o">,</span>
<span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="n">currCounts</span><span class="o">)</span> <span class="o">{</span>
<span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="n">changes</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HashMap</span><span class="o"><>();</span>
@@ -236,7 +240,7 @@ updated. In <code class="highlighter-rouge">WordCountObserver</code>, updates a
database. The export is given the new and old value allowing it to delete the
old value if needed.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="cm">/**
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="cm">/**
* This class exists to provide a single place to put all code related to the
* word count map.
*/</span>
@@ -247,14 +251,14 @@ old value if needed.</p>
<span class="cm">/**
* A helper method for configuring the word count map.
*/</span>
- <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">configure</span><span class="o">(</span><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span><span class="o">,</span> <span class="kt">int</span> <span class="n">numBuckets</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">configure</span><span class="o">(</span><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span><span class="o">,</span> <span class="kt">int</span> <span class="n">numBuckets</span><span class="o">)</span> <span class="o">{</span>
<span class="n">CollisionFreeMap</span><span class="o">.</span><span class="na">configure</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">,</span> <span class="k">new</span> <span class="n">Options</span><span class="o">(</span><span class="n">ID</span><span class="o">,</span> <span class="n">WordCountCombiner</span><span class="o">.</span><span class="na">class</span><span class="o">,</span>
<span class="n">WordCountObserver</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="n">String</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="n">Long</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="n">numBuckets</span><span class="o">));</span>
<span class="o">}</span>
<span class="kd">public</span> <span class="kd">static</span> <span class="kd">class</span> <span class="nc">WordCountCombiner</span> <span class="kd">implements</span> <span class="n">Combiner</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="o">{</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">Optional</span><span class="o"><</span><span class="n">Long</span><span class="o">></span> <span class="n">combine</span><span class="o">(</span><span class="n">String</span> <span class="n">key</span><span class="o">,</span> <span class="n">Iterator</span><span class="o"><</span><span class="n">Long</span><span class="o">></span> <span class="n">updates</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="n">Optional</span><span class="o"><</span><span class="n">Long</span><span class="o">></span> <span class="nf">combine</span><span class="o">(</span><span class="n">String</span> <span class="n">key</span><span class="o">,</span> <span class="n">Iterator</span><span class="o"><</span><span class="n">Long</span><span class="o">></span> <span class="n">updates</span><span class="o">)</span> <span class="o">{</span>
<span class="kt">long</span> <span class="n">sum</span> <span class="o">=</span> <span class="mi">0L</span><span class="o">;</span>
<span class="k">while</span> <span class="o">(</span><span class="n">updates</span><span class="o">.</span><span class="na">hasNext</span><span class="o">())</span> <span class="o">{</span>
@@ -275,12 +279,12 @@ old value if needed.</p>
<span class="kd">private</span> <span class="n">ExportQueue</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">MyDatabaseExport</span><span class="o">></span> <span class="n">exportQ</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">init</span><span class="o">(</span><span class="n">String</span> <span class="n">mapId</span><span class="o">,</span> <span class="n">Context</span> <span class="n">observerContext</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">init</span><span class="o">(</span><span class="n">String</span> <span class="n">mapId</span><span class="o">,</span> <span class="n">Context</span> <span class="n">observerContext</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
<span class="n">exportQ</span> <span class="o">=</span> <span class="n">ExportQueue</span><span class="o">.</span><span class="na">getInstance</span><span class="o">(</span><span class="n">MyExportQ</span><span class="o">.</span><span class="na">ID</span><span class="o">,</span> <span class="n">observerContext</span><span class="o">.</span><span class="na">getAppConfiguration</span><span class="o">());</span>
<span class="o">}</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">updatingValues</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Iterator</span><span class="o"><</span><span class="n">Update</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">>></span> <span class="n">updates</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">updatingValues</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Iterator</span><span class="o"><</span><span class="n">Update</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">>></span> <span class="n">updates</span><span class="o">)</span> <span class="o">{</span>
<span class="k">while</span> <span class="o">(</span><span class="n">updates</span><span class="o">.</span><span class="na">hasNext</span><span class="o">())</span> <span class="o">{</span>
<span class="n">Update</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">></span> <span class="n">update</span> <span class="o">=</span> <span class="n">updates</span><span class="o">.</span><span class="na">next</span><span class="o">();</span>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/export-queue/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/export-queue/index.html b/docs/fluo-recipes/1.0.0-beta-2/export-queue/index.html
index 2119573..ab99041 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/export-queue/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/export-queue/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Export Queue Recipe</h2>
</header>
@@ -103,7 +107,7 @@ Redis, Elasticsearch, MySQL, etc.</p>
To understand what can go wrong consider the following example observer
transaction.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
<span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">TYPEL</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TypeLayer</span><span class="o">(</span><span class="k">new</span> <span class="n">StringEncoder</span><span class="o">());</span>
@@ -111,7 +115,7 @@ transaction.</p>
<span class="n">QuerySystem</span> <span class="n">querySystem</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
<span class="n">TypedTransactionBase</span> <span class="n">ttx</span> <span class="o">=</span> <span class="n">TYPEL</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
<span class="kt">int</span> <span class="n">oldCount</span> <span class="o">=</span> <span class="n">ttx</span><span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">row</span><span class="o">(</span><span class="n">row</span><span class="o">).</span><span class="na">fam</span><span class="o">(</span><span class="s">"meta"</span><span class="o">).</span><span class="na">qual</span><span class="o">(</span><span class="s">"counter1"</span><span class="o">).</span><span class="na">toInteger</span><span class="o">(</span><span class="mi">0</span><span class="o">);</span>
@@ -201,11 +205,11 @@ optimization process</a>.</p>
query system using an export queue. The class below is simple POJO to hold the
count update, this will be used as the value for the export queue.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kd">class</span> <span class="nc">CountUpdate</span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">class</span> <span class="nc">CountUpdate</span> <span class="o">{</span>
<span class="kd">public</span> <span class="kt">int</span> <span class="n">oldCount</span><span class="o">;</span>
<span class="kd">public</span> <span class="kt">int</span> <span class="n">newCount</span><span class="o">;</span>
- <span class="kd">public</span> <span class="n">CountUpdate</span><span class="o">(</span><span class="kt">int</span> <span class="n">oc</span><span class="o">,</span> <span class="kt">int</span> <span class="n">nc</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="nf">CountUpdate</span><span class="o">(</span><span class="kt">int</span> <span class="n">oc</span><span class="o">,</span> <span class="kt">int</span> <span class="n">nc</span><span class="o">)</span> <span class="o">{</span>
<span class="k">this</span><span class="o">.</span><span class="na">oldCount</span> <span class="o">=</span> <span class="n">oc</span><span class="o">;</span>
<span class="k">this</span><span class="o">.</span><span class="na">newCount</span> <span class="o">=</span> <span class="n">nc</span><span class="o">;</span>
<span class="o">}</span>
@@ -218,7 +222,7 @@ modify the FluoConfiguration object with options needed for the export queue.
This FluoConfiguration object should be used to initialize the fluo
application.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="c1">//queue id "ici" means inverted count index, would probably use static final in real application</span>
<span class="n">String</span> <span class="n">exportQueueID</span> <span class="o">=</span> <span class="s">"ici"</span><span class="o">;</span>
@@ -238,19 +242,19 @@ application.</p>
<p>Below is updated version of the observer from above thats now using the export
queue.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
<span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">TYPEL</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TypeLayer</span><span class="o">(</span><span class="k">new</span> <span class="n">StringEncoder</span><span class="o">());</span>
<span class="kd">private</span> <span class="n">ExportQueue</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">></span> <span class="n">exportQueue</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">init</span><span class="o">(</span><span class="n">Context</span> <span class="n">context</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">init</span><span class="o">(</span><span class="n">Context</span> <span class="n">context</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
<span class="n">exportQueue</span> <span class="o">=</span> <span class="n">ExportQueue</span><span class="o">.</span><span class="na">getInstance</span><span class="o">(</span><span class="s">"ici"</span><span class="o">,</span> <span class="n">context</span><span class="o">.</span><span class="na">getAppConfiguration</span><span class="o">());</span>
<span class="o">}</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
<span class="n">TypedTransactionBase</span> <span class="n">ttx</span> <span class="o">=</span> <span class="n">TYPEL</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
<span class="kt">int</span> <span class="n">oldCount</span> <span class="o">=</span> <span class="n">ttx</span><span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">row</span><span class="o">(</span><span class="n">row</span><span class="o">).</span><span class="na">fam</span><span class="o">(</span><span class="s">"meta"</span><span class="o">).</span><span class="na">qual</span><span class="o">(</span><span class="s">"counter1"</span><span class="o">).</span><span class="na">toInteger</span><span class="o">(</span><span class="mi">0</span><span class="o">);</span>
@@ -279,12 +283,12 @@ arriving out of order and multiple times. The purpose of the sequence number
is to help systems receiving data from Fluo process out of order and redundant
data.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="kd">public</span> <span class="kd">class</span> <span class="nc">CountExporter</span> <span class="kd">extends</span> <span class="n">Exporter</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">></span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="kd">public</span> <span class="kd">class</span> <span class="nc">CountExporter</span> <span class="kd">extends</span> <span class="n">Exporter</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">></span> <span class="o">{</span>
<span class="c1">//represents the external query system we want to update from Fluo</span>
<span class="n">QuerySystem</span> <span class="n">querySystem</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">protected</span> <span class="kt">void</span> <span class="n">processExports</span><span class="o">(</span><span class="n">Iterator</span><span class="o"><</span><span class="n">SequencedExport</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">>></span> <span class="n">exportIterator</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">protected</span> <span class="kt">void</span> <span class="nf">processExports</span><span class="o">(</span><span class="n">Iterator</span><span class="o"><</span><span class="n">SequencedExport</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">>></span> <span class="n">exportIterator</span><span class="o">)</span> <span class="o">{</span>
<span class="n">BatchUpdater</span> <span class="n">batchUpdater</span> <span class="o">=</span> <span class="n">querySystem</span><span class="o">.</span><span class="na">getBatchUpdater</span><span class="o">();</span>
<span class="k">while</span><span class="o">(</span><span class="n">exportIterator</span><span class="o">.</span><span class="na">hasNext</span><span class="o">()){</span>
<span class="n">SequencedExport</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">CountUpdate</span><span class="o">></span> <span class="n">exportEntry</span> <span class="o">=</span> <span class="n">exportItertor</span><span class="o">.</span><span class="na">next</span><span class="o">();</span>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/index.html b/docs/fluo-recipes/1.0.0-beta-2/index.html
index 504c7f4..90f6987 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Fluo Recipes 1.0.0-beta-2 Documentation</h2>
</header>
@@ -112,7 +116,7 @@ dependency on Spark.</p>
<p>Below are Maven dependencies for Fluo Recipes.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="nt"><properties></span>
+<div class="language-xml highlighter-rouge"><pre class="highlight"><code> <span class="nt"><properties></span>
<span class="nt"><fluo-recipes.version></span>1.0.0-beta-2<span class="nt"></fluo-recipes.version></span>
<span class="nt"></properties></span>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/recording-tx/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/recording-tx/index.html b/docs/fluo-recipes/1.0.0-beta-2/recording-tx/index.html
index 96f98da..5c9f4df 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/recording-tx/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/recording-tx/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">RecordingTransaction recipe</h2>
</header>
@@ -83,21 +87,21 @@
(i.e GET, SET, or DELETE) to a <code class="highlighter-rouge">TxLog</code> object for later uses such as exporting data. The code below
shows how a RecordingTransaction is created by wrapping a Transaction object:</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
</code></pre>
</div>
<p>A predicate function can be passed to wrap method to select which log entries to record. The code
below only records log entries whose column family is <code class="highlighter-rouge">meta</code>:</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">,</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">,</span>
<span class="n">le</span> <span class="o">-></span> <span class="n">le</span><span class="o">.</span><span class="na">getColumn</span><span class="o">().</span><span class="na">getFamily</span><span class="o">().</span><span class="na">toString</span><span class="o">().</span><span class="na">equals</span><span class="o">(</span><span class="s">"meta"</span><span class="o">));</span>
</code></pre>
</div>
<p>After creating a RecordingTransaction, users can use it as they would use a Transaction object.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">Bytes</span> <span class="n">value</span> <span class="o">=</span> <span class="n">rtx</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">Bytes</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="s">"r1"</span><span class="o">),</span> <span class="k">new</span> <span class="n">Column</span><span class="o">(</span><span class="s">"cf1"</span><span class="o">,</span> <span class="s">"cq1"</span><span class="o">));</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">Bytes</span> <span class="n">value</span> <span class="o">=</span> <span class="n">rtx</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">Bytes</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="s">"r1"</span><span class="o">),</span> <span class="k">new</span> <span class="n">Column</span><span class="o">(</span><span class="s">"cf1"</span><span class="o">,</span> <span class="s">"cq1"</span><span class="o">));</span>
</code></pre>
</div>
@@ -108,7 +112,7 @@ necessary if you want to determine the changes made by the transaction.</p>
<p>When you are done operating on the transaction, you can retrieve the TxLog using the following code:</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">TxLog</span> <span class="n">myTxLog</span> <span class="o">=</span> <span class="n">rtx</span><span class="o">.</span><span class="na">getTxLog</span><span class="o">()</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">TxLog</span> <span class="n">myTxLog</span> <span class="o">=</span> <span class="n">rtx</span><span class="o">.</span><span class="na">getTxLog</span><span class="o">()</span>
</code></pre>
</div>
@@ -117,14 +121,14 @@ performed by the transaction in a TxLog. In this example, a GET (if data exists
will be logged. This TxLog can be added to an export queue and later used to export updates from
Fluo.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyObserver</span> <span class="kd">extends</span> <span class="n">AbstractObserver</span> <span class="o">{</span>
<span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">TYPEL</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TypeLayer</span><span class="o">(</span><span class="k">new</span> <span class="n">StringEncoder</span><span class="o">());</span>
<span class="kd">private</span> <span class="n">ExportQueue</span><span class="o"><</span><span class="n">Bytes</span><span class="o">,</span> <span class="n">TxLog</span><span class="o">></span> <span class="n">exportQueue</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="n">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">process</span><span class="o">(</span><span class="n">TransactionBase</span> <span class="n">tx</span><span class="o">,</span> <span class="n">Bytes</span> <span class="n">row</span><span class="o">,</span> <span class="n">Column</span> <span class="n">col</span><span class="o">)</span> <span class="o">{</span>
<span class="c1">// create recording transaction (rtx)</span>
<span class="n">RecordingTransactionBase</span> <span class="n">rtx</span> <span class="o">=</span> <span class="n">RecordingTransactionBase</span><span class="o">.</span><span class="na">wrap</span><span class="o">(</span><span class="n">tx</span><span class="o">);</span>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/row-hasher/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/row-hasher/index.html b/docs/fluo-recipes/1.0.0-beta-2/row-hasher/index.html
index 00b24bf..1d13682 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/row-hasher/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/row-hasher/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Row hash prefix recipe</h2>
</header>
@@ -108,7 +112,7 @@ balancing of the prefix.</p>
<h2 id="example-use">Example Use</h2>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="kn">import</span> <span class="nn">io.fluo.api.data.Bytes</span><span class="o">;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kn">import</span> <span class="nn">io.fluo.api.data.Bytes</span><span class="o">;</span>
<span class="kn">import</span> <span class="nn">io.fluo.recipes.common.Pirtos</span><span class="o">;</span>
<span class="kn">import</span> <span class="nn">io.fluo.recipes.data.RowHasher</span><span class="o">;</span>
@@ -117,11 +121,11 @@ balancing of the prefix.</p>
<span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">RowHasher</span> <span class="n">PAGE_ROW_HASHER</span> <span class="o">=</span> <span class="k">new</span> <span class="n">RowHasher</span><span class="o">(</span><span class="s">"p"</span><span class="o">);</span>
<span class="c1">//Provide one place to obtain row hasher. </span>
- <span class="kd">public</span> <span class="kd">static</span> <span class="n">RowHasher</span> <span class="n">getPageRowHasher</span><span class="o">(){</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span class="n">RowHasher</span> <span class="nf">getPageRowHasher</span><span class="o">(){</span>
<span class="k">return</span> <span class="n">PAGE_ROW_HASHER</span><span class="o">;</span>
<span class="o">}</span>
- <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span>
<span class="n">RowHasher</span> <span class="n">pageRowHasher</span> <span class="o">=</span> <span class="n">getPageRowHasher</span><span class="o">();</span>
<span class="n">String</span> <span class="n">revUrl</span> <span class="o">=</span> <span class="s">"org.wikipedia/accumulo"</span><span class="o">;</span>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/serialization/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/serialization/index.html b/docs/fluo-recipes/1.0.0-beta-2/serialization/index.html
index 5144ae8..b4491aa 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/serialization/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/serialization/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Serializing Data</h2>
</header>
@@ -89,7 +93,7 @@ first step is to implement <a href="/apidocs/fluo-recipes/1.0.0-beta-2/io/fluo/r
configure Fluo Recipes to use the custom implementation. This needs to be done
before initializing Fluo. Below is an example of how to do this.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="c1">//assume MySerializer implements SimpleSerializer</span>
<span class="n">SimpleSerializer</span><span class="o">.</span><span class="na">setSetserlializer</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">,</span> <span class="n">MySerializer</span><span class="o">.</span><span class="na">class</span><span class="o">);</span>
<span class="c1">//initialize Fluo using fluoConfig</span>
@@ -110,7 +114,7 @@ example below shows how to do this.</p>
need to be registered with Kryo. This could be done by creating a KryoFactory
like the following.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code>
<span class="kn">package</span> <span class="n">com</span><span class="o">.</span><span class="na">foo</span><span class="o">;</span>
<span class="kn">import</span> <span class="nn">com.esotericsoftware.kryo.Kryo</span><span class="o">;</span>
@@ -121,7 +125,7 @@ like the following.</p>
<span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyKryoFactory</span> <span class="kd">implements</span> <span class="n">KryoFactory</span> <span class="o">{</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">Kryo</span> <span class="n">create</span><span class="o">()</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="n">Kryo</span> <span class="nf">create</span><span class="o">()</span> <span class="o">{</span>
<span class="n">Kryo</span> <span class="n">kryo</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Kryo</span><span class="o">();</span>
<span class="c1">//Explicitly assign each class a unique id here to ensure its stable over</span>
@@ -141,7 +145,7 @@ like the following.</p>
<p>Fluo Recipes must be configured to use this factory. The following code shows
how to do this.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="n">KryoSimplerSerializer</span><span class="o">.</span><span class="na">setKryoFactory</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">,</span> <span class="n">MyKryoFactory</span><span class="o">.</span><span class="na">class</span><span class="o">);</span>
<span class="c1">//initialize Fluo using fluoConfig</span>
</code></pre>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/table-optimization/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/table-optimization/index.html b/docs/fluo-recipes/1.0.0-beta-2/table-optimization/index.html
index ca6c779..6c358db 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/table-optimization/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/table-optimization/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Fluo Table Optimization</h2>
</header>
@@ -90,7 +94,7 @@ want to use them in production.</p>
<h2 id="java-example">Java Example</h2>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConf</span> <span class="o">=</span> <span class="o">...</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConf</span> <span class="o">=</span> <span class="o">...</span>
<span class="c1">//export queue configure method will return table optimizations it would like made</span>
<span class="n">ExportQueue</span><span class="o">.</span><span class="na">configure</span><span class="o">(</span><span class="n">fluoConf</span><span class="o">,</span> <span class="o">...);</span>
@@ -123,7 +127,7 @@ selective optimizations is need look into using the following methods instead.</
recipes from the command line. This should be done after configuring reciped
and initializing Fluo. Below are example command for initializing in this way.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code>
+<div class="language-bash highlighter-rouge"><pre class="highlight"><code>
<span class="c">#create application </span>
fluo new app1
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/testing/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/testing/index.html b/docs/fluo-recipes/1.0.0-beta-2/testing/index.html
index 403abdd..2a9b49e 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/testing/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/testing/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Testing</h2>
</header>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/1.0.0-beta-2/transient/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/1.0.0-beta-2/transient/index.html b/docs/fluo-recipes/1.0.0-beta-2/transient/index.html
index 03c4cae..15372af 100644
--- a/docs/fluo-recipes/1.0.0-beta-2/transient/index.html
+++ b/docs/fluo-recipes/1.0.0-beta-2/transient/index.html
@@ -74,6 +74,10 @@
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo Recipes made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Transient data</h2>
</header>
@@ -106,7 +110,7 @@ transient ranges when configured. If you would like to register your own
transient ranges, use <a href="/apidocs/fluo-recipes/1.0.0-beta-2/io/fluo/recipes/common/TransientRegistry.html">TransientRegistry</a>. Below is a simple example of
using this.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="n">TransientRegistry</span> <span class="n">transientRegistry</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TransientRegistry</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">.</span><span class="na">getAppConfiguration</span><span class="o">());</span>
<span class="n">transientRegistry</span><span class="o">.</span><span class="na">addTransientRange</span><span class="o">(</span><span class="k">new</span> <span class="n">RowRange</span><span class="o">(</span><span class="n">startRow</span><span class="o">,</span> <span class="n">endRow</span><span class="o">));</span>
@@ -122,7 +126,7 @@ need to periodically compact transient ranges if using a recipe that registers
them. Using <a href="/apidocs/fluo-recipes/1.0.0-beta-2/io/fluo/recipes/accumulo/ops/TableOperations.html">TableOperations</a> this can be done with one line of Java code
like the following.</p>
-<div class="highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">FluoConfiguration</span> <span class="n">fluoConfig</span> <span class="o">=</span> <span class="o">...;</span>
<span class="n">TableOperations</span><span class="o">.</span><span class="na">compactTransient</span><span class="o">(</span><span class="n">fluoConfig</span><span class="o">);</span>
</code></pre>
</div>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo-recipes/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo-recipes/index.html b/docs/fluo-recipes/index.html
index d2842c5..7108720 100644
--- a/docs/fluo-recipes/index.html
+++ b/docs/fluo-recipes/index.html
@@ -77,8 +77,10 @@
</header>
<article id="page-content">
- <ul>
- <li><a href="/docs/fluo-recipes/1.0.0-beta-2/">1.0.0-beta-2</a> - March 19, 2016 - <strong>Latest Release</strong></li>
+ <p>Fluo Recipes documentation before Apache incubation:</p>
+
+<ul>
+ <li><a href="/docs/fluo-recipes/1.0.0-beta-2/">1.0.0-beta-2</a> - March 19, 2016</li>
<li><a href="/docs/fluo-recipes/1.0.0-beta-1/">1.0.0-beta-1</a> - January 13, 2016</li>
</ul>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo/1.0.0-alpha-1/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo/1.0.0-alpha-1/index.html b/docs/fluo/1.0.0-alpha-1/index.html
index feeb241..bc02726 100644
--- a/docs/fluo/1.0.0-alpha-1/index.html
+++ b/docs/fluo/1.0.0-alpha-1/index.html
@@ -76,6 +76,10 @@
<div class="alert alert-danger" role="alert">These docs are for Fluo 1.0.0-alpha-1 which is an old version! Check out the <a href="/docs/fluo/1.0.0-beta-2/">latest docs</a>!</div>
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Fluo 1.0.0-alpha-1 Documentation</h2>
</header>
http://git-wip-us.apache.org/repos/asf/incubator-fluo-website/blob/b532c453/docs/fluo/1.0.0-alpha-1/stress/index.html
----------------------------------------------------------------------
diff --git a/docs/fluo/1.0.0-alpha-1/stress/index.html b/docs/fluo/1.0.0-alpha-1/stress/index.html
index 56a082a..496a1da 100644
--- a/docs/fluo/1.0.0-alpha-1/stress/index.html
+++ b/docs/fluo/1.0.0-alpha-1/stress/index.html
@@ -76,6 +76,10 @@
<div class="alert alert-danger" role="alert">These docs are for Fluo 1.0.0-alpha-1 which is an old version! Check out the <a href="/docs/fluo/1.0.0-beta-2/">latest docs</a>!</div>
+
+ <div class="alert alert-danger" role="alert">These docs are for a release of Fluo made before Apache incubation.</div>
+
+
<header class="post-header">
<h2 class="post-title">Fluo Stress Test</h2>
</header>