aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--other/java/client/src/main/java/seaweedfs/client/SeaweedOutputStream.java5
1 files changed, 5 insertions, 0 deletions
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;