You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by hj...@apache.org on 2020/12/25 09:55:14 UTC
[pulsar] branch master updated: update 263 and 271 (#9062)
This is an automated email from the ASF dual-hosted git repository.
hjf pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 924e584 update 263 and 271 (#9062)
924e584 is described below
commit 924e58475c94de4f909d423c677b2cdf31bb56f7
Author: sijia-w <53...@users.noreply.github.com>
AuthorDate: Fri Dec 25 10:54:38 2020 +0100
update 263 and 271 (#9062)
---
site2/website/versioned_docs/version-2.6.3/adaptors-spark.md | 7 +------
site2/website/versioned_docs/version-2.6.3/adaptors-storm.md | 6 ++----
site2/website/versioned_docs/version-2.7.1/adaptors-spark.md | 6 +-----
site2/website/versioned_docs/version-2.7.1/adaptors-storm.md | 6 ++----
4 files changed, 6 insertions(+), 19 deletions(-)
diff --git a/site2/website/versioned_docs/version-2.6.3/adaptors-spark.md b/site2/website/versioned_docs/version-2.6.3/adaptors-spark.md
index 02e5c83..5db24e1 100644
--- a/site2/website/versioned_docs/version-2.6.3/adaptors-spark.md
+++ b/site2/website/versioned_docs/version-2.6.3/adaptors-spark.md
@@ -69,9 +69,4 @@ Pass an instance of `SparkStreamingPulsarReceiver` to the `receiverStream` metho
JavaReceiverInputDStream<byte[]> lineDStream = jsc.receiverStream(pulsarReceiver);
```
-
-## Example
-
-You can find a complete example [here](https://github.com/apache/pulsar/tree/master/examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/SparkStreamingPulsarReceiverExample.java).
-In this example, the number of messages which contain the string "Pulsar" in received messages is counted.
-
+For a complete example, click [here](https://github.com/apache/pulsar-adapters/blob/master/examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/SparkStreamingPulsarReceiverExample.java). In this example, the number of messages that contain the string "Pulsar" in received messages is counted.
diff --git a/site2/website/versioned_docs/version-2.6.3/adaptors-storm.md b/site2/website/versioned_docs/version-2.6.3/adaptors-storm.md
index 431aa29..b6ac9cd 100644
--- a/site2/website/versioned_docs/version-2.6.3/adaptors-storm.md
+++ b/site2/website/versioned_docs/version-2.6.3/adaptors-storm.md
@@ -53,6 +53,8 @@ spoutConf.setMessageToValuesMapper(messageToValuesMapper);
PulsarSpout spout = new PulsarSpout(spoutConf);
```
+For a complete example, click [here](https://github.com/apache/pulsar-adapters/blob/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/PulsarSpoutTest.java).
+
## Pulsar Bolt
The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the `TupleToMessageMapper` provided by the client.
@@ -85,7 +87,3 @@ boltConf.setTupleToMessageMapper(tupleToMessageMapper);
// Create a Pulsar Bolt
PulsarBolt bolt = new PulsarBolt(boltConf);
```
-
-## Example
-
-You can find a complete example [here](https://github.com/apache/pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java).
diff --git a/site2/website/versioned_docs/version-2.7.1/adaptors-spark.md b/site2/website/versioned_docs/version-2.7.1/adaptors-spark.md
index e8ec85c..1dbb756 100644
--- a/site2/website/versioned_docs/version-2.7.1/adaptors-spark.md
+++ b/site2/website/versioned_docs/version-2.7.1/adaptors-spark.md
@@ -69,9 +69,5 @@ Pass an instance of `SparkStreamingPulsarReceiver` to the `receiverStream` metho
JavaReceiverInputDStream<byte[]> lineDStream = jsc.receiverStream(pulsarReceiver);
```
-
-## Example
-
-You can find a complete example [here](https://github.com/apache/pulsar/tree/master/examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/SparkStreamingPulsarReceiverExample.java).
-In this example, the number of messages which contain the string "Pulsar" in received messages is counted.
+For a complete example, click [here](https://github.com/apache/pulsar-adapters/blob/master/examples/spark/src/main/java/org/apache/spark/streaming/receiver/example/SparkStreamingPulsarReceiverExample.java). In this example, the number of messages that contain the string "Pulsar" in received messages is counted.
diff --git a/site2/website/versioned_docs/version-2.7.1/adaptors-storm.md b/site2/website/versioned_docs/version-2.7.1/adaptors-storm.md
index 931b79a..c5b0f78 100644
--- a/site2/website/versioned_docs/version-2.7.1/adaptors-storm.md
+++ b/site2/website/versioned_docs/version-2.7.1/adaptors-storm.md
@@ -53,6 +53,8 @@ spoutConf.setMessageToValuesMapper(messageToValuesMapper);
PulsarSpout spout = new PulsarSpout(spoutConf);
```
+For a complete example, click [here](https://github.com/apache/pulsar-adapters/blob/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/PulsarSpoutTest.java).
+
## Pulsar Bolt
The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the `TupleToMessageMapper` provided by the client.
@@ -85,7 +87,3 @@ boltConf.setTupleToMessageMapper(tupleToMessageMapper);
// Create a Pulsar Bolt
PulsarBolt bolt = new PulsarBolt(boltConf);
```
-
-## Example
-
-You can find a complete example [here](https://github.com/apache/pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java).