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 <jerry.boyang.p...@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 mme...@apache.org.