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 <[email protected]>
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).
