You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2018/05/17 19:59:58 UTC
[incubator-pulsar] branch master updated: Remove old comment (#1803)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new f09eb3c Remove old comment (#1803)
f09eb3c is described below
commit f09eb3cdbd8542c9f19efbb281891aa0c435116b
Author: Boyang Jerry Peng <je...@gmail.com>
AuthorDate: Thu May 17 12:59:55 2018 -0700
Remove old comment (#1803)
---
.../core/src/main/java/org/apache/pulsar/io/core/Sink.java | 10 +---------
1 file changed, 1 insertion(+), 9 deletions(-)
diff --git a/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java
index 0265e77..a84a47e 100644
--- a/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java
+++ b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java
@@ -31,15 +31,7 @@ public interface Sink<T> extends AutoCloseable{
* @throws Exception IO type exceptions when opening a connector
*/
void open(final Map<String, Object> config) throws Exception;
-
- /**
- * Attempt to publish a type safe collection of messages
- *
- * @param value output value
- * @return Completable future fo async publish request
- */
-
-
+
/**
* Write a message to Sink
* @param inputRecordContext Context of value
--
To stop receiving notification emails like this one, please contact
mmerli@apache.org.