You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2018/09/27 09:08:07 UTC
[pulsar] branch asf-site updated: Updated site at revision 30f6935
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/pulsar.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 0949858 Updated site at revision 30f6935
0949858 is described below
commit 09498584a1414a841519db503ad0d587fb09b1f1
Author: jenkins <bu...@apache.org>
AuthorDate: Thu Sep 27 09:07:58 2018 +0000
Updated site at revision 30f6935
---
content/api/client/index-all.html | 12 +++++
.../org/apache/pulsar/client/api/Message.html | 59 ++++++++++++++++++----
.../pulsar/client/api/TypedMessageBuilder.html | 35 ++++++++++---
.../docs/latest/project/BinaryProtocol/index.html | 20 ++++++++
content/ja/project/BinaryProtocol/index.html | 20 ++++++++
content/swagger/swagger.json | 34 ++++++-------
6 files changed, 147 insertions(+), 33 deletions(-)
diff --git a/content/api/client/index-all.html b/content/api/client/index-all.html
index 444b630..ef7030e 100644
--- a/content/api/client/index-all.html
+++ b/content/api/client/index-all.html
@@ -710,6 +710,10 @@
<dd>
<div class="block">Get the key of the message</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/Message.html#getKeyBytes--">getKeyBytes()</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api">Message</a></dt>
+<dd>
+<div class="block">Get bytes in key.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/Producer.html#getLastSequenceId--">getLastSequenceId()</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/Producer.html" title="interface in org.apache.pulsar.client.api">Producer</a></dt>
<dd>
<div class="block">Get the last sequence id that was published by this producer.</div>
@@ -972,6 +976,10 @@
</a>
<h2 class="title">H</h2>
<dl>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/Message.html#hasBase64EncodedKey--">hasBase64EncodedKey()</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/Message.html" title="interface in org.apache.pulsar.client.api">Message</a></dt>
+<dd>
+<div class="block">Check whether the key has been base64 encoded.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/AuthenticationDataProvider.html#hasDataForHttp--">hasDataForHttp()</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/AuthenticationDataProvider.html" title="interface in org.apache.pulsar.client.api">AuthenticationDataProvider</a></dt>
<dd>
<div class="block">Check if data for HTTP are available.</div>
@@ -1089,6 +1097,10 @@
<dd>
<div class="block">Sets the key of the message for routing policy</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/pulsar/client/api/TypedMessageBuilder.html#keyBytes-byte:A-">keyBytes(byte[])</a></span> - Method in interface org.apache.pulsar.client.api.<a href="org/apache/pulsar/client/api/TypedMessageBuilder.html" title="interface in org.apache.pulsar.client.api">TypedMessageBuilder</a></dt>
+<dd>
+<div class="block">Sets the bytes of the key of the message for routing policy.</div>
+</dd>
</dl>
<a name="I:L">
<!-- -->
diff --git a/content/api/client/org/apache/pulsar/client/api/Message.html b/content/api/client/org/apache/pulsar/client/api/Message.html
index 5b5ab6d..674ff7a 100644
--- a/content/api/client/org/apache/pulsar/client/api/Message.html
+++ b/content/api/client/org/apache/pulsar/client/api/Message.html
@@ -17,7 +17,7 @@
catch(err) {
}
//-->
-var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6};
+var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -145,52 +145,64 @@ var activeTableTab = "activeTableTab";
</td>
</tr>
<tr id="i4" class="altColor">
+<td class="colFirst"><code>byte[]</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#getKeyBytes--">getKeyBytes</a></span>()</code>
+<div class="block">Get bytes in key.</div>
+</td>
+</tr>
+<tr id="i5" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/MessageId.html" title="interface in org.apache.pulsar.client.api">MessageId</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#getMessageId--">getMessageId</a></span>()</code>
<div class="block">Get the unique message ID associated with this message.</div>
</td>
</tr>
-<tr id="i5" class="rowColor">
+<tr id="i6" class="altColor">
<td class="colFirst"><code>String</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#getProducerName--">getProducerName</a></span>()</code>
<div class="block">Get the producer name who produced this message.</div>
</td>
</tr>
-<tr id="i6" class="altColor">
+<tr id="i7" class="rowColor">
<td class="colFirst"><code>Map<String,String></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#getProperties--">getProperties</a></span>()</code>
<div class="block">Return the properties attached to the message.</div>
</td>
</tr>
-<tr id="i7" class="rowColor">
+<tr id="i8" class="altColor">
<td class="colFirst"><code>String</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#getProperty-java.lang.String-">getProperty</a></span>(String name)</code>
<div class="block">Get the value of a specific property</div>
</td>
</tr>
-<tr id="i8" class="altColor">
+<tr id="i9" class="rowColor">
<td class="colFirst"><code>long</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#getPublishTime--">getPublishTime</a></span>()</code>
<div class="block">Get the publish time of this message.</div>
</td>
</tr>
-<tr id="i9" class="rowColor">
+<tr id="i10" class="altColor">
<td class="colFirst"><code>long</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#getSequenceId--">getSequenceId</a></span>()</code>
<div class="block">Get the sequence id associated with this message.</div>
</td>
</tr>
-<tr id="i10" class="altColor">
+<tr id="i11" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/Message.html" title="type parameter in Message">T</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#getValue--">getValue</a></span>()</code> </td>
</tr>
-<tr id="i11" class="rowColor">
+<tr id="i12" class="altColor">
+<td class="colFirst"><code>boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#hasBase64EncodedKey--">hasBase64EncodedKey</a></span>()</code>
+<div class="block">Check whether the key has been base64 encoded.</div>
+</td>
+</tr>
+<tr id="i13" class="rowColor">
<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#hasKey--">hasKey</a></span>()</code>
<div class="block">Check whether the message has a key</div>
</td>
</tr>
-<tr id="i12" class="altColor">
+<tr id="i14" class="altColor">
<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/Message.html#hasProperty-java.lang.String-">hasProperty</a></span>(String name)</code>
<div class="block">Check whether the message has a specific property attached.</div>
@@ -398,6 +410,35 @@ var activeTableTab = "activeTableTab";
</dl>
</li>
</ul>
+<a name="hasBase64EncodedKey--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>hasBase64EncodedKey</h4>
+<pre>boolean hasBase64EncodedKey()</pre>
+<div class="block">Check whether the key has been base64 encoded.</div>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>true if the key is base64 encoded, false otherwise</dd>
+</dl>
+</li>
+</ul>
+<a name="getKeyBytes--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>getKeyBytes</h4>
+<pre>byte[] getKeyBytes()</pre>
+<div class="block">Get bytes in key. If the key has been base64 encoded, it is decoded before being returned.
+ Otherwise, if the key is a plain string, this method returns the UTF_8 encoded bytes of the string.</div>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>the key in byte[] form</dd>
+</dl>
+</li>
+</ul>
<a name="getEncryptionCtx--">
<!-- -->
</a>
diff --git a/content/api/client/org/apache/pulsar/client/api/TypedMessageBuilder.html b/content/api/client/org/apache/pulsar/client/api/TypedMessageBuilder.html
index 16d7518..252018b 100644
--- a/content/api/client/org/apache/pulsar/client/api/TypedMessageBuilder.html
+++ b/content/api/client/org/apache/pulsar/client/api/TypedMessageBuilder.html
@@ -17,7 +17,7 @@
catch(err) {
}
//-->
-var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6};
+var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -150,42 +150,48 @@ extends Serializable</pre>
</tr>
<tr id="i3" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="interface in org.apache.pulsar.client.api">TypedMessageBuilder</a><<a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="type parameter in TypedMessageBuilder">T</a>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html#keyBytes-byte:A-">keyBytes</a></span>(byte[] key)</code>
+<div class="block">Sets the bytes of the key of the message for routing policy.</div>
+</td>
+</tr>
+<tr id="i4" class="altColor">
+<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="interface in org.apache.pulsar.client.api">TypedMessageBuilder</a><<a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="type parameter in TypedMessageBuilder">T</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html#properties-java.util.Map-">properties</a></span>(Map<String,String> properties)</code>
<div class="block">Add all the properties in the provided map</div>
</td>
</tr>
-<tr id="i4" class="altColor">
+<tr id="i5" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="interface in org.apache.pulsar.client.api">TypedMessageBuilder</a><<a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="type parameter in TypedMessageBuilder">T</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html#property-java.lang.String-java.lang.String-">property</a></span>(String name,
String value)</code>
<div class="block">Sets a new property on a message.</div>
</td>
</tr>
-<tr id="i5" class="rowColor">
+<tr id="i6" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="interface in org.apache.pulsar.client.api">TypedMessageBuilder</a><<a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="type parameter in TypedMessageBuilder">T</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html#replicationClusters-java.util.List-">replicationClusters</a></span>(List<String> clusters)</code>
<div class="block">Override the replication clusters for this message.</div>
</td>
</tr>
-<tr id="i6" class="altColor">
+<tr id="i7" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/MessageId.html" title="interface in org.apache.pulsar.client.api">MessageId</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html#send--">send</a></span>()</code>
<div class="block">Send a message synchronously.</div>
</td>
</tr>
-<tr id="i7" class="rowColor">
+<tr id="i8" class="altColor">
<td class="colFirst"><code>CompletableFuture<<a href="../../../../../org/apache/pulsar/client/api/MessageId.html" title="interface in org.apache.pulsar.client.api">MessageId</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html#sendAsync--">sendAsync</a></span>()</code>
<div class="block">Send a message asynchronously</div>
</td>
</tr>
-<tr id="i8" class="altColor">
+<tr id="i9" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="interface in org.apache.pulsar.client.api">TypedMessageBuilder</a><<a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="type parameter in TypedMessageBuilder">T</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html#sequenceId-long-">sequenceId</a></span>(long sequenceId)</code>
<div class="block">Specify a custom sequence id for the message being published.</div>
</td>
</tr>
-<tr id="i9" class="rowColor">
+<tr id="i10" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="interface in org.apache.pulsar.client.api">TypedMessageBuilder</a><<a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="type parameter in TypedMessageBuilder">T</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html#value-T-">value</a></span>(<a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="type parameter in TypedMessageBuilder">T</a> value)</code>
<div class="block">Set a domain object on the message</div>
@@ -284,6 +290,21 @@ extends Serializable</pre>
</dl>
</li>
</ul>
+<a name="keyBytes-byte:A-">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>keyBytes</h4>
+<pre><a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="interface in org.apache.pulsar.client.api">TypedMessageBuilder</a><<a href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html" title="type parameter in TypedMessageBuilder">T</a>> keyBytes(byte[] key)</pre>
+<div class="block">Sets the bytes of the key of the message for routing policy.
+ Internally the bytes will be base64 encoded.</div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>key</code> - routing key for message, in byte array form</dd>
+</dl>
+</li>
+</ul>
<a name="value-java.lang.Object-">
<!-- -->
</a><a name="value-T-">
diff --git a/content/docs/latest/project/BinaryProtocol/index.html b/content/docs/latest/project/BinaryProtocol/index.html
index e73006a..5d74a12 100644
--- a/content/docs/latest/project/BinaryProtocol/index.html
+++ b/content/docs/latest/project/BinaryProtocol/index.html
@@ -5677,6 +5677,16 @@ if this field is omitted, `publish_time` can be used for the purpose of `event_t
<td></td>
<td></td>
</tr>
+
+ <tr>
+ <td class="wrap">partition_key_b64_encoded</td>
+
+ <td class="wrap">bool</td>
+
+ <td>optional</td>
+ <td>false</td>
+ <td></td>
+ </tr>
<!-- for field in fields -->
</tbody>
</table>
@@ -5826,6 +5836,16 @@ if this field is omitted, `publish_time` can be used for the purpose of `event_t
<td>the timestamp that this event occurs. it is typically set by applications.
if this field is omitted, `publish_time` can be used for the purpose of `event_time`.</td>
</tr>
+
+ <tr>
+ <td class="wrap">partition_key_b64_encoded</td>
+
+ <td class="wrap">bool</td>
+
+ <td>optional</td>
+ <td>false</td>
+ <td></td>
+ </tr>
<!-- for field in fields -->
</tbody>
</table>
diff --git a/content/ja/project/BinaryProtocol/index.html b/content/ja/project/BinaryProtocol/index.html
index e074147..f595218 100644
--- a/content/ja/project/BinaryProtocol/index.html
+++ b/content/ja/project/BinaryProtocol/index.html
@@ -5252,6 +5252,16 @@ if this field is omitted, `publish_time` can be used for the purpose of `event_t
<td></td>
<td></td>
</tr>
+
+ <tr>
+ <td class="wrap">partition_key_b64_encoded</td>
+
+ <td class="wrap">bool</td>
+
+ <td>optional</td>
+ <td>false</td>
+ <td></td>
+ </tr>
<!-- for field in fields -->
</tbody>
</table>
@@ -5401,6 +5411,16 @@ if this field is omitted, `publish_time` can be used for the purpose of `event_t
<td>the timestamp that this event occurs. it is typically set by applications.
if this field is omitted, `publish_time` can be used for the purpose of `event_time`.</td>
</tr>
+
+ <tr>
+ <td class="wrap">partition_key_b64_encoded</td>
+
+ <td class="wrap">bool</td>
+
+ <td>optional</td>
+ <td>false</td>
+ <td></td>
+ </tr>
<!-- for field in fields -->
</tbody>
</table>
diff --git a/content/swagger/swagger.json b/content/swagger/swagger.json
index 0a04335..3aa50a9 100644
--- a/content/swagger/swagger.json
+++ b/content/swagger/swagger.json
@@ -6697,22 +6697,31 @@
"type" : "number",
"format" : "double"
},
- "underLoaded" : {
- "type" : "boolean"
+ "msgThroughputIn" : {
+ "type" : "number",
+ "format" : "double"
+ },
+ "msgThroughputOut" : {
+ "type" : "number",
+ "format" : "double"
},
"overLoaded" : {
"type" : "boolean"
},
+ "underLoaded" : {
+ "type" : "boolean"
+ },
"loadReportType" : {
"type" : "string"
},
- "cpu" : {
- "$ref" : "#/definitions/ResourceUsage"
+ "lastUpdate" : {
+ "type" : "integer",
+ "format" : "int64"
},
- "memory" : {
+ "directMemory" : {
"$ref" : "#/definitions/ResourceUsage"
},
- "directMemory" : {
+ "cpu" : {
"$ref" : "#/definitions/ResourceUsage"
},
"bandwidthIn" : {
@@ -6721,17 +6730,8 @@
"bandwidthOut" : {
"$ref" : "#/definitions/ResourceUsage"
},
- "lastUpdate" : {
- "type" : "integer",
- "format" : "int64"
- },
- "msgThroughputOut" : {
- "type" : "number",
- "format" : "double"
- },
- "msgThroughputIn" : {
- "type" : "number",
- "format" : "double"
+ "memory" : {
+ "$ref" : "#/definitions/ResourceUsage"
}
}
},