This is an automated email from the ASF dual-hosted git repository.
sijie 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 270af32 [doc] [Issue #4661] fix broken links on 'Develop connectors'
page (#4674)
270af32 is described below
commit 270af329cc31ef4f24243acd6c6983a6006d20ac
Author: Guillaume Rosauro <[email protected]>
AuthorDate: Fri Jul 5 07:00:35 2019 +0200
[doc] [Issue #4661] fix broken links on 'Develop connectors' page (#4674)
---
site2/docs/io-develop.md | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/site2/docs/io-develop.md b/site2/docs/io-develop.md
index 828281f..ff15e26 100644
--- a/site2/docs/io-develop.md
+++ b/site2/docs/io-develop.md
@@ -42,7 +42,7 @@ save the `SourceContext` for futher usage.
void open(final Map<String, Object> config, SourceContext sourceContext)
throws Exception;
```
-The main task for a Source implementor is to implement {@inject:
github:`read`:/master/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Source.java#L41}
+The main task for a Source implementor is to implement {@inject:
github:`read`:/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Source.java#L41}
method.
```java
@@ -56,7 +56,7 @@ method.
```
The implementation should be blocking on this method if nothing to return. It
should never return
-`null`. The returned {@inject:
github:`Record`:/master/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Record.java#L28}
should encapsulates the information that is needed by
+`null`. The returned {@inject:
github:`Record`:/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Record.java#L28}
should encapsulates the information that is needed by
Pulsar IO runtime.
These information includes:
@@ -76,14 +76,14 @@ Additionally, the implemention of the record should provide
two methods: `ack` a
two methods will be used by Pulsar IO connector to acknowledge the records
that it has done
processing and fail the records that it has failed to process.
-{@inject:
github:`KafkaSource`:/master/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java}
is a good example to follow.
+{@inject:
github:`KafkaSource`:/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java}
is a good example to follow.
#### Develop a sink connector
Developing a sink connector is as easy as developing a source connector. You
just need to
-implement {@inject:
github:`Sink`:/master/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java}
interface.
+implement {@inject:
github:`Sink`:/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java}
interface.
-Similarly, you first need to implement the {@inject:
github:`open`:/master/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java#L36}
method to initialize all the necessary resources
+Similarly, you first need to implement the {@inject:
github:`open`:/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java#L36}
method to initialize all the necessary resources
before implementing the {@inject:
github:`write`:/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java#L44}
method.
```java
