Skip to content

Commit

Permalink
update 263 and 271 (apache#9062)
Browse files Browse the repository at this point in the history
  • Loading branch information
sijia-w authored Dec 25, 2020
1 parent f5c344e commit 924e584
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 19 deletions.
7 changes: 1 addition & 6 deletions site2/website/versioned_docs/version-2.6.3/adaptors-spark.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.
6 changes: 2 additions & 4 deletions site2/website/versioned_docs/version-2.6.3/adaptors-storm.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down Expand Up @@ -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).
6 changes: 1 addition & 5 deletions site2/website/versioned_docs/version-2.7.1/adaptors-spark.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.

6 changes: 2 additions & 4 deletions site2/website/versioned_docs/version-2.7.1/adaptors-storm.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down Expand Up @@ -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).

0 comments on commit 924e584

Please sign in to comment.