From ce416d765f42f673e84723703f75c8d0ab151889 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Thu, 4 Feb 2021 20:22:40 -0800 Subject: [PATCH] Java: SeaweedOutputStream add replication option --- .../src/main/java/seaweedfs/client/SeaweedOutputStream.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java b/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java index 925a56bdd..94f34b221 100644 --- a/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java +++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java @@ -34,6 +34,11 @@ public class SeaweedOutputStream extends OutputStream { private boolean shouldSaveMetadata = false; public SeaweedOutputStream(FilerGrpcClient filerGrpcClient, final String fullpath) { + this(filerGrpcClient, fullpath, "000"); + } + + public SeaweedOutputStream(FilerGrpcClient filerGrpcClient, final String fullpath, final String replication) { + this.replication = replication; this.filerGrpcClient = filerGrpcClient; this.path = fullpath; this.position = 0;