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 <bui...@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" } } },