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 <53718687+siji...@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).