diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-12-27 23:40:23 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-12-27 23:40:23 -0800 |
| commit | 9123d799b86a26345d33187463f6d6ed78564fdb (patch) | |
| tree | 5d5699337a470be024bfd60f66166792b1123d4b /other/java/hdfs/src/test | |
| parent | 319ab6d98ff6f2d17ebda87fc4cfe65bf02667ef (diff) | |
| download | seaweedfs-9123d799b86a26345d33187463f6d6ed78564fdb.tar.xz seaweedfs-9123d799b86a26345d33187463f6d6ed78564fdb.zip | |
refactor
Diffstat (limited to 'other/java/hdfs/src/test')
| -rw-r--r-- | other/java/hdfs/src/test/java/seaweed/hdfs/SeaweedReadTest.java | 65 |
1 files changed, 0 insertions, 65 deletions
diff --git a/other/java/hdfs/src/test/java/seaweed/hdfs/SeaweedReadTest.java b/other/java/hdfs/src/test/java/seaweed/hdfs/SeaweedReadTest.java deleted file mode 100644 index e3ab97910..000000000 --- a/other/java/hdfs/src/test/java/seaweed/hdfs/SeaweedReadTest.java +++ /dev/null @@ -1,65 +0,0 @@ -package seaweed.hdfs; - -import org.junit.Test; -import seaweedfs.client.FilerProto; - -import java.util.ArrayList; -import java.util.List; - -import static org.junit.Assert.assertEquals; - -public class SeaweedReadTest { - - @Test - public void testNonOverlappingVisibleIntervals() { - List<FilerProto.FileChunk> chunks = new ArrayList<>(); - chunks.add(FilerProto.FileChunk.newBuilder() - .setFileId("aaa") - .setOffset(0) - .setSize(100) - .setMtime(1000) - .build()); - chunks.add(FilerProto.FileChunk.newBuilder() - .setFileId("bbb") - .setOffset(100) - .setSize(133) - .setMtime(2000) - .build()); - - List<SeaweedRead.VisibleInterval> visibleIntervals = SeaweedRead.nonOverlappingVisibleIntervals(chunks); - for (SeaweedRead.VisibleInterval visibleInterval : visibleIntervals) { - System.out.println("visible:" + visibleInterval); - } - - assertEquals(visibleIntervals.size(), 2); - - SeaweedRead.VisibleInterval visibleInterval = visibleIntervals.get(0); - assertEquals(visibleInterval.start, 0); - assertEquals(visibleInterval.stop, 100); - assertEquals(visibleInterval.modifiedTime, 1000); - assertEquals(visibleInterval.fileId, "aaa"); - - visibleInterval = visibleIntervals.get(1); - assertEquals(visibleInterval.start, 100); - assertEquals(visibleInterval.stop, 233); - assertEquals(visibleInterval.modifiedTime, 2000); - assertEquals(visibleInterval.fileId, "bbb"); - - List<SeaweedRead.ChunkView> chunkViews = SeaweedRead.viewFromVisibles(visibleIntervals, 0, 233); - - SeaweedRead.ChunkView chunkView = chunkViews.get(0); - assertEquals(chunkView.offset, 0); - assertEquals(chunkView.size, 100); - assertEquals(chunkView.logicOffset, 0); - assertEquals(chunkView.fileId, "aaa"); - - chunkView = chunkViews.get(1); - assertEquals(chunkView.offset, 0); - assertEquals(chunkView.size, 133); - assertEquals(chunkView.logicOffset, 100); - assertEquals(chunkView.fileId, "bbb"); - - - } - -} |
