[incubator-pulsar] branch asf-site updated: Updated site at revision 6ef9df9

Wed, 18 Jul 2018 07:07:23 -0700 

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/asf-site by this push:
     new c56cd3a  Updated site at revision 6ef9df9
c56cd3a is described below

commit c56cd3a5d6965558a6192dfd621fe1ee60c2ec78
Author: jenkins <[email protected]>
AuthorDate: Wed Jul 18 14:07:01 2018 +0000

    Updated site at revision 6ef9df9
---
 content/api/pulsar-functions/allclasses-frame.html |   1 +
 .../api/pulsar-functions/allclasses-noframe.html   |   1 +
 content/api/pulsar-functions/index-all.html        |  32 +++++
 .../org/apache/pulsar/functions/api/Function.html  |   4 +-
 .../functions/api/{SerDe.html => Record.html}      | 154 +++++++++++++++++----
 .../org/apache/pulsar/functions/api/SerDe.html     |   4 +-
 .../apache/pulsar/functions/api/package-frame.html |   1 +
 .../pulsar/functions/api/package-summary.html      |   6 +
 .../apache/pulsar/functions/api/package-tree.html  |   1 +
 content/api/pulsar-functions/overview-tree.html    |   1 +
 content/docs/latest/deployment/cluster/index.html  |   4 +
 11 files changed, 176 insertions(+), 33 deletions(-)

diff --git a/content/api/pulsar-functions/allclasses-frame.html 
b/content/api/pulsar-functions/allclasses-frame.html
index 9686a5d..1026fe6 100644
--- a/content/api/pulsar-functions/allclasses-frame.html
+++ b/content/api/pulsar-functions/allclasses-frame.html
@@ -16,6 +16,7 @@
 <li><a href="org/apache/pulsar/functions/api/Function.html" title="interface 
in org.apache.pulsar.functions.api" target="classFrame"><span 
class="interfaceName">Function</span></a></li>
 <li><a href="org/apache/pulsar/functions/api/utils/IdentityFunction.html" 
title="class in org.apache.pulsar.functions.api.utils" 
target="classFrame">IdentityFunction</a></li>
 <li><a href="org/apache/pulsar/functions/api/utils/JavaSerDe.html" 
title="class in org.apache.pulsar.functions.api.utils" 
target="classFrame">JavaSerDe</a></li>
+<li><a href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api" target="classFrame"><span 
class="interfaceName">Record</span></a></li>
 <li><a href="org/apache/pulsar/functions/api/SerDe.html" title="interface in 
org.apache.pulsar.functions.api" target="classFrame"><span 
class="interfaceName">SerDe</span></a></li>
 </ul>
 </div>
diff --git a/content/api/pulsar-functions/allclasses-noframe.html 
b/content/api/pulsar-functions/allclasses-noframe.html
index 3b4e7d3..1692e94 100644
--- a/content/api/pulsar-functions/allclasses-noframe.html
+++ b/content/api/pulsar-functions/allclasses-noframe.html
@@ -16,6 +16,7 @@
 <li><a href="org/apache/pulsar/functions/api/Function.html" title="interface 
in org.apache.pulsar.functions.api"><span 
class="interfaceName">Function</span></a></li>
 <li><a href="org/apache/pulsar/functions/api/utils/IdentityFunction.html" 
title="class in org.apache.pulsar.functions.api.utils">IdentityFunction</a></li>
 <li><a href="org/apache/pulsar/functions/api/utils/JavaSerDe.html" 
title="class in org.apache.pulsar.functions.api.utils">JavaSerDe</a></li>
+<li><a href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api"><span 
class="interfaceName">Record</span></a></li>
 <li><a href="org/apache/pulsar/functions/api/SerDe.html" title="interface in 
org.apache.pulsar.functions.api"><span 
class="interfaceName">SerDe</span></a></li>
 </ul>
 </div>
diff --git a/content/api/pulsar-functions/index-all.html 
b/content/api/pulsar-functions/index-all.html
index d282f26..42565fb 100644
--- a/content/api/pulsar-functions/index-all.html
+++ b/content/api/pulsar-functions/index-all.html
@@ -76,6 +76,10 @@
 <dd>
 <div class="block">By default acknowledgement management is done transparently 
by Pulsar Functions framework.</div>
 </dd>
+<dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Record.html#ack--">ack()</a></span> - 
Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api">Record</a></dt>
+<dd>
+<div class="block">Acknowledge that this record is fully processed</div>
+</dd>
 <dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/utils/IdentityFunction.html#apply-java.lang.Object-">apply(Object)</a></span>
 - Method in class org.apache.pulsar.functions.api.utils.<a 
href="org/apache/pulsar/functions/api/utils/IdentityFunction.html" title="class 
in org.apache.pulsar.functions.api.utils">IdentityFunction</a></dt>
 <dd>&nbsp;</dd>
 </dl>
@@ -112,6 +116,10 @@
 </a>
 <h2 class="title">F</h2>
 <dl>
+<dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Record.html#fail--">fail()</a></span> - 
Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api">Record</a></dt>
+<dd>
+<div class="block">To indicate that this record has failed to be 
processed</div>
+</dd>
 <dt><a href="org/apache/pulsar/functions/api/Function.html" title="interface 
in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Function</span></a>&lt;<a 
href="org/apache/pulsar/functions/api/Function.html" title="type parameter in 
Function">I</a>,<a href="org/apache/pulsar/functions/api/Function.html" 
title="type parameter in Function">O</a>&gt; - Interface in <a 
href="org/apache/pulsar/functions/api/package-summary.html">org.apache.pulsar.functions.api</a></dt>
 <dd>
 <div class="block">This is the core interface of the function api.</div>
@@ -150,6 +158,10 @@
 <dd>
 <div class="block">The id of the instance that invokes this function.</div>
 </dd>
+<dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Record.html#getKey--">getKey()</a></span> 
- Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api">Record</a></dt>
+<dd>
+<div class="block">Return a key if the key has one associated</div>
+</dd>
 <dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Context.html#getLogger--">getLogger()</a></span>
 - Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Context.html" title="interface in 
org.apache.pulsar.functions.api">Context</a></dt>
 <dd>
 <div class="block">The logger object that can be used to log in a 
function</div>
@@ -171,6 +183,18 @@
 <dd>
 <div class="block">Get the output topic of the function</div>
 </dd>
+<dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Record.html#getPartitionId--">getPartitionId()</a></span>
 - Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api">Record</a></dt>
+<dd>
+<div class="block">Retrieves the partition information if any of the 
record.</div>
+</dd>
+<dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Record.html#getProperties--">getProperties()</a></span>
 - Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api">Record</a></dt>
+<dd>
+<div class="block">Retrieves user-defined properties attached to record.</div>
+</dd>
+<dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Record.html#getRecordSequence--">getRecordSequence()</a></span>
 - Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api">Record</a></dt>
+<dd>
+<div class="block">Retrieves the sequence of the record from a source 
partition.</div>
+</dd>
 <dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Context.html#getState-java.lang.String-">getState(String)</a></span>
 - Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Context.html" title="interface in 
org.apache.pulsar.functions.api">Context</a></dt>
 <dd>
 <div class="block">Retrieve the state value for the key.</div>
@@ -191,6 +215,10 @@
 <dd>
 <div class="block">Get any user-defined key/value or a default value if none 
is present</div>
 </dd>
+<dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Record.html#getValue--">getValue()</a></span>
 - Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api">Record</a></dt>
+<dd>
+<div class="block">Retrieves the actual data of the record</div>
+</dd>
 </dl>
 <a name="I:I">
 <!--   -->
@@ -261,6 +289,10 @@
 </a>
 <h2 class="title">R</h2>
 <dl>
+<dt><a href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api"><span 
class="typeNameLink">Record</span></a>&lt;<a 
href="org/apache/pulsar/functions/api/Record.html" title="type parameter in 
Record">T</a>&gt; - Interface in <a 
href="org/apache/pulsar/functions/api/package-summary.html">org.apache.pulsar.functions.api</a></dt>
+<dd>
+<div class="block">Pulsar Connect's Record interface.</div>
+</dd>
 <dt><span class="memberNameLink"><a 
href="org/apache/pulsar/functions/api/Context.html#recordMetric-java.lang.String-double-">recordMetric(String,
 double)</a></span> - Method in interface org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Context.html" title="interface in 
org.apache.pulsar.functions.api">Context</a></dt>
 <dd>
 <div class="block">Record a user defined metric</div>
diff --git 
a/content/api/pulsar-functions/org/apache/pulsar/functions/api/Function.html 
b/content/api/pulsar-functions/org/apache/pulsar/functions/api/Function.html
index 5f8609c..74ee85f 100644
--- a/content/api/pulsar-functions/org/apache/pulsar/functions/api/Function.html
+++ b/content/api/pulsar-functions/org/apache/pulsar/functions/api/Function.html
@@ -48,7 +48,7 @@ var activeTableTab = "activeTableTab";
 <div class="subNav">
 <ul class="navList">
 <li><a href="../../../../../org/apache/pulsar/functions/api/Context.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li><a href="../../../../../org/apache/pulsar/functions/api/SerDe.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/functions/api/Record.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
 </ul>
 <ul class="navList">
 <li><a 
href="../../../../../index.html?org/apache/pulsar/functions/api/Function.html" 
target="_top">Frames</a></li>
@@ -198,7 +198,7 @@ public interface <span 
class="typeNameLabel">Function&lt;I,O&gt;</span></pre>
 <div class="subNav">
 <ul class="navList">
 <li><a href="../../../../../org/apache/pulsar/functions/api/Context.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li><a href="../../../../../org/apache/pulsar/functions/api/SerDe.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/functions/api/Record.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
 </ul>
 <ul class="navList">
 <li><a 
href="../../../../../index.html?org/apache/pulsar/functions/api/Function.html" 
target="_top">Frames</a></li>
diff --git 
a/content/api/pulsar-functions/org/apache/pulsar/functions/api/SerDe.html 
b/content/api/pulsar-functions/org/apache/pulsar/functions/api/Record.html
similarity index 53%
copy from 
content/api/pulsar-functions/org/apache/pulsar/functions/api/SerDe.html
copy to content/api/pulsar-functions/org/apache/pulsar/functions/api/Record.html
index 3753a10..414d1ff 100644
--- a/content/api/pulsar-functions/org/apache/pulsar/functions/api/SerDe.html
+++ b/content/api/pulsar-functions/org/apache/pulsar/functions/api/Record.html
@@ -3,7 +3,7 @@
 <html lang="en">
 <head>
 <!-- Generated by javadoc -->
-<title>SerDe (Pulsar Functions Java SDK)</title>
+<title>Record (Pulsar Functions Java SDK)</title>
 <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../script.js"></script>
 </head>
@@ -11,14 +11,14 @@
 <script type="text/javascript"><!--
     try {
         if (location.href.indexOf('is-external=true') == -1) {
-            parent.document.title="SerDe (Pulsar Functions Java SDK)";
+            parent.document.title="Record (Pulsar Functions Java SDK)";
         }
     }
     catch(err) {
     }
 //-->
-var methods = {"i0":6,"i1":6};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],4:["t3","Abstract Methods"]};
+var methods = {"i0":18,"i1":18,"i2":6,"i3":18,"i4":18,"i5":18,"i6":6};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],4:["t3","Abstract Methods"],16:["t5","Default Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
 var tableTab = "tableTab";
@@ -48,11 +48,11 @@ var activeTableTab = "activeTableTab";
 <div class="subNav">
 <ul class="navList">
 <li><a href="../../../../../org/apache/pulsar/functions/api/Function.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li>Next&nbsp;Class</li>
+<li><a href="../../../../../org/apache/pulsar/functions/api/SerDe.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
 </ul>
 <ul class="navList">
-<li><a 
href="../../../../../index.html?org/apache/pulsar/functions/api/SerDe.html" 
target="_top">Frames</a></li>
-<li><a href="SerDe.html" target="_top">No&nbsp;Frames</a></li>
+<li><a 
href="../../../../../index.html?org/apache/pulsar/functions/api/Record.html" 
target="_top">Frames</a></li>
+<li><a href="Record.html" target="_top">No&nbsp;Frames</a></li>
 </ul>
 <ul class="navList" id="allclasses_navbar_top">
 <li><a href="../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
@@ -91,20 +91,16 @@ var activeTableTab = "activeTableTab";
 <!-- ======== START OF CLASS DATA ======== -->
 <div class="header">
 <div class="subTitle">org.apache.pulsar.functions.api</div>
-<h2 title="Interface SerDe" class="title">Interface SerDe&lt;T&gt;</h2>
+<h2 title="Interface Record" class="title">Interface Record&lt;T&gt;</h2>
 </div>
 <div class="contentContainer">
 <div class="description">
 <ul class="blockList">
 <li class="blockList">
-<dl>
-<dt>All Known Implementing Classes:</dt>
-<dd><a 
href="../../../../../org/apache/pulsar/functions/api/utils/DefaultSerDe.html" 
title="class in org.apache.pulsar.functions.api.utils">DefaultSerDe</a>, <a 
href="../../../../../org/apache/pulsar/functions/api/utils/JavaSerDe.html" 
title="class in org.apache.pulsar.functions.api.utils">JavaSerDe</a></dd>
-</dl>
 <hr>
 <br>
-<pre>public interface <span class="typeNameLabel">SerDe&lt;T&gt;</span></pre>
-<div class="block">An interface for serializer/deserializer.</div>
+<pre>public interface <span class="typeNameLabel">Record&lt;T&gt;</span></pre>
+<div class="block">Pulsar Connect's Record interface. Record encapsulates the 
information about a record being read from a Source.</div>
 </li>
 </ul>
 </div>
@@ -118,18 +114,52 @@ var activeTableTab = "activeTableTab";
 </a>
 <h3>Method Summary</h3>
 <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" 
summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span 
class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a 
href="javascript:show(2);">Instance Methods</a></span><span 
class="tabEnd">&nbsp;</span></span><span id="t3" class="tableTab"><span><a 
href="javascript:show(4);">Abstract Methods</a></span><span 
class="tabEnd">&nbsp;</span></span></caption>
+<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span 
class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a 
href="javascript:show(2);">Instance Methods</a></span><span 
class="tabEnd">&nbsp;</span></span><span id="t3" class="tableTab"><span><a 
href="javascript:show(4);">Abstract Methods</a></span><span 
class="tabEnd">&nbsp;</span></span><span id="t5" class="tableTab"><span><a 
href="javascript:show(16);">Default Methods</a></span><span class="tabE [...]
 <tr>
 <th class="colFirst" scope="col">Modifier and Type</th>
 <th class="colLast" scope="col">Method and Description</th>
 </tr>
 <tr id="i0" class="altColor">
-<td class="colFirst"><code><a 
href="../../../../../org/apache/pulsar/functions/api/SerDe.html" title="type 
parameter in SerDe">T</a></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../org/apache/pulsar/functions/api/SerDe.html#deserialize-byte:A-">deserialize</a></span>(byte[]&nbsp;input)</code>&nbsp;</td>
+<td class="colFirst"><code>default void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../org/apache/pulsar/functions/api/Record.html#ack--">ack</a></span>()</code>
+<div class="block">Acknowledge that this record is fully processed</div>
+</td>
 </tr>
 <tr id="i1" class="rowColor">
-<td class="colFirst"><code>byte[]</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../org/apache/pulsar/functions/api/SerDe.html#serialize-T-">serialize</a></span>(<a
 href="../../../../../org/apache/pulsar/functions/api/SerDe.html" title="type 
parameter in SerDe">T</a>&nbsp;input)</code>&nbsp;</td>
+<td class="colFirst"><code>default void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../org/apache/pulsar/functions/api/Record.html#fail--">fail</a></span>()</code>
+<div class="block">To indicate that this record has failed to be 
processed</div>
+</td>
+</tr>
+<tr id="i2" class="altColor">
+<td class="colFirst"><code>Optional&lt;String&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../org/apache/pulsar/functions/api/Record.html#getKey--">getKey</a></span>()</code>
+<div class="block">Return a key if the key has one associated</div>
+</td>
+</tr>
+<tr id="i3" class="rowColor">
+<td class="colFirst"><code>default Optional&lt;String&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../org/apache/pulsar/functions/api/Record.html#getPartitionId--">getPartitionId</a></span>()</code>
+<div class="block">Retrieves the partition information if any of the 
record.</div>
+</td>
+</tr>
+<tr id="i4" class="altColor">
+<td class="colFirst"><code>default Map&lt;String,String&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../org/apache/pulsar/functions/api/Record.html#getProperties--">getProperties</a></span>()</code>
+<div class="block">Retrieves user-defined properties attached to record.</div>
+</td>
+</tr>
+<tr id="i5" class="rowColor">
+<td class="colFirst"><code>default Optional&lt;Long&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../org/apache/pulsar/functions/api/Record.html#getRecordSequence--">getRecordSequence</a></span>()</code>
+<div class="block">Retrieves the sequence of the record from a source 
partition.</div>
+</td>
+</tr>
+<tr id="i6" class="altColor">
+<td class="colFirst"><code><a 
href="../../../../../org/apache/pulsar/functions/api/Record.html" title="type 
parameter in Record">T</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../org/apache/pulsar/functions/api/Record.html#getValue--">getValue</a></span>()</code>
+<div class="block">Retrieves the actual data of the record</div>
+</td>
 </tr>
 </table>
 </li>
@@ -146,24 +176,90 @@ var activeTableTab = "activeTableTab";
 <!--   -->
 </a>
 <h3>Method Detail</h3>
-<a name="deserialize-byte:A-">
+<a name="getKey--">
+<!--   -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getKey</h4>
+<pre>Optional&lt;String&gt;&nbsp;getKey()</pre>
+<div class="block">Return a key if the key has one associated</div>
+</li>
+</ul>
+<a name="getValue--">
+<!--   -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getValue</h4>
+<pre><a href="../../../../../org/apache/pulsar/functions/api/Record.html" 
title="type parameter in Record">T</a>&nbsp;getValue()</pre>
+<div class="block">Retrieves the actual data of the record</div>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>The record data</dd>
+</dl>
+</li>
+</ul>
+<a name="getPartitionId--">
+<!--   -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getPartitionId</h4>
+<pre>default&nbsp;Optional&lt;String&gt;&nbsp;getPartitionId()</pre>
+<div class="block">Retrieves the partition information if any of the 
record.</div>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>The partition id where the</dd>
+</dl>
+</li>
+</ul>
+<a name="getRecordSequence--">
+<!--   -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getRecordSequence</h4>
+<pre>default&nbsp;Optional&lt;Long&gt;&nbsp;getRecordSequence()</pre>
+<div class="block">Retrieves the sequence of the record from a source 
partition.</div>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>Sequence Id associated with the record</dd>
+</dl>
+</li>
+</ul>
+<a name="getProperties--">
 <!--   -->
 </a>
 <ul class="blockList">
 <li class="blockList">
-<h4>deserialize</h4>
-<pre><a href="../../../../../org/apache/pulsar/functions/api/SerDe.html" 
title="type parameter in SerDe">T</a>&nbsp;deserialize(byte[]&nbsp;input)</pre>
+<h4>getProperties</h4>
+<pre>default&nbsp;Map&lt;String,String&gt;&nbsp;getProperties()</pre>
+<div class="block">Retrieves user-defined properties attached to record.</div>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>Map of user-properties</dd>
+</dl>
 </li>
 </ul>
-<a name="serialize-java.lang.Object-">
+<a name="ack--">
 <!--   -->
-</a><a name="serialize-T-">
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>ack</h4>
+<pre>default&nbsp;void&nbsp;ack()</pre>
+<div class="block">Acknowledge that this record is fully processed</div>
+</li>
+</ul>
+<a name="fail--">
 <!--   -->
 </a>
 <ul class="blockListLast">
 <li class="blockList">
-<h4>serialize</h4>
-<pre>byte[]&nbsp;serialize(<a 
href="../../../../../org/apache/pulsar/functions/api/SerDe.html" title="type 
parameter in SerDe">T</a>&nbsp;input)</pre>
+<h4>fail</h4>
+<pre>default&nbsp;void&nbsp;fail()</pre>
+<div class="block">To indicate that this record has failed to be 
processed</div>
 </li>
 </ul>
 </li>
@@ -194,11 +290,11 @@ var activeTableTab = "activeTableTab";
 <div class="subNav">
 <ul class="navList">
 <li><a href="../../../../../org/apache/pulsar/functions/api/Function.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li>Next&nbsp;Class</li>
+<li><a href="../../../../../org/apache/pulsar/functions/api/SerDe.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
 </ul>
 <ul class="navList">
-<li><a 
href="../../../../../index.html?org/apache/pulsar/functions/api/SerDe.html" 
target="_top">Frames</a></li>
-<li><a href="SerDe.html" target="_top">No&nbsp;Frames</a></li>
+<li><a 
href="../../../../../index.html?org/apache/pulsar/functions/api/Record.html" 
target="_top">Frames</a></li>
+<li><a href="Record.html" target="_top">No&nbsp;Frames</a></li>
 </ul>
 <ul class="navList" id="allclasses_navbar_bottom">
 <li><a href="../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
diff --git 
a/content/api/pulsar-functions/org/apache/pulsar/functions/api/SerDe.html 
b/content/api/pulsar-functions/org/apache/pulsar/functions/api/SerDe.html
index 3753a10..67a5df5 100644
--- a/content/api/pulsar-functions/org/apache/pulsar/functions/api/SerDe.html
+++ b/content/api/pulsar-functions/org/apache/pulsar/functions/api/SerDe.html
@@ -47,7 +47,7 @@ var activeTableTab = "activeTableTab";
 </div>
 <div class="subNav">
 <ul class="navList">
-<li><a href="../../../../../org/apache/pulsar/functions/api/Function.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/functions/api/Record.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
 <li>Next&nbsp;Class</li>
 </ul>
 <ul class="navList">
@@ -193,7 +193,7 @@ var activeTableTab = "activeTableTab";
 </div>
 <div class="subNav">
 <ul class="navList">
-<li><a href="../../../../../org/apache/pulsar/functions/api/Function.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
+<li><a href="../../../../../org/apache/pulsar/functions/api/Record.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
 <li>Next&nbsp;Class</li>
 </ul>
 <ul class="navList">
diff --git 
a/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-frame.html
 
b/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-frame.html
index 441ca3d..30a8668 100644
--- 
a/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-frame.html
+++ 
b/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-frame.html
@@ -14,6 +14,7 @@
 <ul title="Interfaces">
 <li><a href="Context.html" title="interface in 
org.apache.pulsar.functions.api" target="classFrame"><span 
class="interfaceName">Context</span></a></li>
 <li><a href="Function.html" title="interface in 
org.apache.pulsar.functions.api" target="classFrame"><span 
class="interfaceName">Function</span></a></li>
+<li><a href="Record.html" title="interface in org.apache.pulsar.functions.api" 
target="classFrame"><span class="interfaceName">Record</span></a></li>
 <li><a href="SerDe.html" title="interface in org.apache.pulsar.functions.api" 
target="classFrame"><span class="interfaceName">SerDe</span></a></li>
 </ul>
 </div>
diff --git 
a/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-summary.html
 
b/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-summary.html
index 7f1b2cc..f4ae11a 100644
--- 
a/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-summary.html
+++ 
b/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-summary.html
@@ -97,6 +97,12 @@
 </td>
 </tr>
 <tr class="altColor">
+<td class="colFirst"><a 
href="../../../../../org/apache/pulsar/functions/api/Record.html" 
title="interface in org.apache.pulsar.functions.api">Record</a>&lt;T&gt;</td>
+<td class="colLast">
+<div class="block">Pulsar Connect's Record interface.</div>
+</td>
+</tr>
+<tr class="rowColor">
 <td class="colFirst"><a 
href="../../../../../org/apache/pulsar/functions/api/SerDe.html" 
title="interface in org.apache.pulsar.functions.api">SerDe</a>&lt;T&gt;</td>
 <td class="colLast">
 <div class="block">An interface for serializer/deserializer.</div>
diff --git 
a/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-tree.html
 
b/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-tree.html
index e675ba6..849b0a0 100644
--- 
a/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-tree.html
+++ 
b/content/api/pulsar-functions/org/apache/pulsar/functions/api/package-tree.html
@@ -79,6 +79,7 @@
 <ul>
 <li type="circle">org.apache.pulsar.functions.api.<a 
href="../../../../../org/apache/pulsar/functions/api/Context.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Context</span></a></li>
 <li type="circle">org.apache.pulsar.functions.api.<a 
href="../../../../../org/apache/pulsar/functions/api/Function.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Function</span></a>&lt;I,O&gt;</li>
+<li type="circle">org.apache.pulsar.functions.api.<a 
href="../../../../../org/apache/pulsar/functions/api/Record.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">Record</span></a>&lt;T&gt;</li>
 <li type="circle">org.apache.pulsar.functions.api.<a 
href="../../../../../org/apache/pulsar/functions/api/SerDe.html" 
title="interface in org.apache.pulsar.functions.api"><span 
class="typeNameLink">SerDe</span></a>&lt;T&gt;</li>
 </ul>
 </div>
diff --git a/content/api/pulsar-functions/overview-tree.html 
b/content/api/pulsar-functions/overview-tree.html
index 9ebba27..e469a08 100644
--- a/content/api/pulsar-functions/overview-tree.html
+++ b/content/api/pulsar-functions/overview-tree.html
@@ -90,6 +90,7 @@
 <ul>
 <li type="circle">org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Context.html" title="interface in 
org.apache.pulsar.functions.api"><span 
class="typeNameLink">Context</span></a></li>
 <li type="circle">org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Function.html" title="interface in 
org.apache.pulsar.functions.api"><span 
class="typeNameLink">Function</span></a>&lt;I,O&gt;</li>
+<li type="circle">org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/Record.html" title="interface in 
org.apache.pulsar.functions.api"><span 
class="typeNameLink">Record</span></a>&lt;T&gt;</li>
 <li type="circle">org.apache.pulsar.functions.api.<a 
href="org/apache/pulsar/functions/api/SerDe.html" title="interface in 
org.apache.pulsar.functions.api"><span 
class="typeNameLink">SerDe</span></a>&lt;T&gt;</li>
 </ul>
 </div>
diff --git a/content/docs/latest/deployment/cluster/index.html 
b/content/docs/latest/deployment/cluster/index.html
index b61d337..bb298eb 100644
--- a/content/docs/latest/deployment/cluster/index.html
+++ b/content/docs/latest/deployment/cluster/index.html
@@ -2306,6 +2306,10 @@
 
 <p>This will create an ephemeral BookKeeper <span class="popover-term" 
tabindex="0" title="What is a ledger?" data-placement="top" data-content="An 
append-only data structure in BookKeeper that is used to persistently store 
messages in Pulsar topics." data-toggle="popover" 
data-trigger="focus">ledger</span> on the local bookie, write a few entries, 
read them back, and finally delete the ledger.</p>
 
+<p>Starting from Pulsar 2.1 release, Bookies start <a 
href="http://bookkeeper.apache.org/docs/latest/admin/autorecovery/";>AutoRecovery</a>
 daemons by default. Those AutoRecovery daemons will monitor the healthy of the 
bookkeeper cluster and automatically re-replicate entries for those 
under-replicated ledgers.
+Since <code class="highlighter-rouge">AutoRecovery</code> deamons are 
stateless processes, if you would like to run <code 
class="highlighter-rouge">AutoRecovery</code> as a separate service, you can 
also disable <code class="highlighter-rouge">AutoRecovery</code> on bookies by 
setting <code class="highlighter-rouge">autoRecoveryDaemonEnabled</code> to 
<code class="highlighter-rouge">false</code> in your <code 
class="highlighter-rouge">bookkeeper.conf</code> file. And you can follow the i 
[...]
+<a 
href="http://bookkeeper.apache.org/docs/latest/admin/autorecovery/";>bookkeeper 
documentation</a> to run <code class="highlighter-rouge">AutoRecovery</code> as 
separate processes.</p>
+
 <h2 id="deploying-pulsar-brokers">Deploying Pulsar brokers</h2>
 
 <p>Pulsar <span class="popover-term" tabindex="0" title="What is a broker?" 
data-placement="top" data-content="A stateless component of Pulsar clusters 
that runs two other components: an HTTP server exposing a REST interface for 
administration and topic lookup and a dispatcher that handles all message 
transers. Pulsar clusters typically consist of multiple brokers." 
data-toggle="popover" data-trigger="focus">brokers</span> are the last thing 
you need to deploy in your Pulsar cluster. Bro [...]

Reply via email to