Java: SeaweedOutputStream add replication option

4 years ago · ce416d765f
1 changed files with 5 additions and 0 deletions
--- 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;