From 502554887f58915c077462372db4e2813eac3f92 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Thu, 4 Feb 2021 18:44:57 -0800 Subject: Java: add SeaweedInputStream example --- .../main/java/seaweedfs/client/SeaweedInputStream.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) (limited to 'other/java/client/src/main') diff --git a/other/java/client/src/main/java/seaweedfs/client/SeaweedInputStream.java b/other/java/client/src/main/java/seaweedfs/client/SeaweedInputStream.java index 312e77aa2..519ff0fd9 100644 --- a/other/java/client/src/main/java/seaweedfs/client/SeaweedInputStream.java +++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedInputStream.java @@ -26,6 +26,21 @@ public class SeaweedInputStream extends InputStream { private boolean closed = false; + public SeaweedInputStream( + final FilerGrpcClient filerGrpcClient, + final String dir, final String name) throws IOException { + this.filerGrpcClient = filerGrpcClient; + this.path = dir; + FilerClient filerClient = new FilerClient(filerGrpcClient); + this.entry = filerClient.lookupEntry(dir, name); + this.contentLength = SeaweedRead.fileSize(entry); + + this.visibleIntervalList = SeaweedRead.nonOverlappingVisibleIntervals(filerGrpcClient, entry.getChunksList()); + + LOG.debug("new path:{} entry:{} visibleIntervalList:{}", path, entry, visibleIntervalList); + + } + public SeaweedInputStream( final FilerGrpcClient filerGrpcClient, final String path, -- cgit v1.2.3