[pulsar] branch master updated: Remove the private method that is never used (#8819)

[mmerli]

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/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 750408e  Remove the private method that is never used (#8819)
750408e is described below

commit 750408e8baa9be154a58c8777ebc2e24072e47d5
Author: Yunze Xu <xyzinfern...@163.com>
AuthorDate: Thu Dec 3 12:54:46 2020 -0600

    Remove the private method that is never used (#8819)
---
 .../storage/bookkeeper/DLOutputStream.java          | 21 ---------------------
 1 file changed, 21 deletions(-)

diff --git 
a/pulsar-package-management/bookkeeper-storage/src/main/java/org/apache/pulsar/packages/management/storage/bookkeeper/DLOutputStream.java
 
b/pulsar-package-management/bookkeeper-storage/src/main/java/org/apache/pulsar/packages/management/storage/bookkeeper/DLOutputStream.java
index e56fbb3..a951cd4 100644
--- 
a/pulsar-package-management/bookkeeper-storage/src/main/java/org/apache/pulsar/packages/management/storage/bookkeeper/DLOutputStream.java
+++ 
b/pulsar-package-management/bookkeeper-storage/src/main/java/org/apache/pulsar/packages/management/storage/bookkeeper/DLOutputStream.java
@@ -84,27 +84,6 @@ class DLOutputStream {
             .thenCompose(this::writeAsync);
     }
 
-    /**
-     * Write a ByteBuf data to the distribute log.
-     *
-     * @param data the data we need to write
-     * @return
-     */
-    private CompletableFuture<DLOutputStream> writeAsync(ByteBuf data) {
-        synchronized (this) {
-            offset += data.readableBytes();
-            LogRecord record = new LogRecord(offset, data);
-            log.info("execute write to the dlog " + offset);
-            return writer.write(record).whenComplete((dlsn, throwable) -> {
-                if (throwable != null) {
-                    throwable.printStackTrace();
-                } else {
-                    log.info("DLSN is {} {}", dlsn.toString(), offset);
-                }
-            }).thenApply(ignore -> this);
-        }
-    }
-
     private CompletableFuture<DLOutputStream> writeAsync(List<LogRecord> 
records) {
         return writer.writeBulk(records).thenApply(ignore -> this);
     }