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.