diff options
Diffstat (limited to 'other/java/unzip')
| -rw-r--r-- | other/java/unzip/pom.xml | 32 | ||||
| -rw-r--r-- | other/java/unzip/src/main/java/com/example/test/Example.java | 56 |
2 files changed, 0 insertions, 88 deletions
diff --git a/other/java/unzip/pom.xml b/other/java/unzip/pom.xml deleted file mode 100644 index 7cbb56ec3..000000000 --- a/other/java/unzip/pom.xml +++ /dev/null @@ -1,32 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<project xmlns="http://maven.apache.org/POM/4.0.0" - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> - <modelVersion>4.0.0</modelVersion> - - <groupId>org.example</groupId> - <artifactId>unzip</artifactId> - <version>1.0-SNAPSHOT</version> - <dependencies> - <dependency> - <groupId>com.github.chrislusf</groupId> - <artifactId>seaweedfs-client</artifactId> - <version>1.5.4</version> - <scope>compile</scope> - </dependency> - <dependency> - <groupId>com.github.chrislusf</groupId> - <artifactId>seaweedfs-hadoop2-client</artifactId> - <version>1.5.4</version> - <scope>compile</scope> - </dependency> - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-common</artifactId> - <version>2.9.2</version> - <scope>compile</scope> - </dependency> - </dependencies> - - -</project>
\ No newline at end of file diff --git a/other/java/unzip/src/main/java/com/example/test/Example.java b/other/java/unzip/src/main/java/com/example/test/Example.java deleted file mode 100644 index 3d22329a8..000000000 --- a/other/java/unzip/src/main/java/com/example/test/Example.java +++ /dev/null @@ -1,56 +0,0 @@ -package com.example.test; - -import seaweed.hdfs.SeaweedInputStream; -import seaweedfs.client.FilerClient; -import seaweedfs.client.FilerGrpcClient; - -import java.io.FileInputStream; -import java.io.IOException; -import java.io.InputStream; -import java.util.zip.ZipEntry; -import java.util.zip.ZipInputStream; - -public class Example { - - public static FilerClient filerClient = new FilerClient("localhost", 18888); - public static FilerGrpcClient filerGrpcClient = new FilerGrpcClient("localhost", 18888); - - public static void main(String[] args) throws IOException { - - long startTime = System.currentTimeMillis(); - // 本地模式，速度很快 - parseZip("/Users/chris/tmp/test.zip"); - - long startTime2 = System.currentTimeMillis(); - - long localProcessTime = startTime2 - startTime; - - // swfs读取，慢 - SeaweedInputStream seaweedInputStream = new SeaweedInputStream( - filerGrpcClient, - new org.apache.hadoop.fs.FileSystem.Statistics(""), - "/", - filerClient.lookupEntry("/", "test.zip") - ); - parseZip(seaweedInputStream); - - long swProcessTime = System.currentTimeMillis() - startTime2; - - System.out.println("Local time: " + localProcessTime); - System.out.println("SeaweedFS time: " + swProcessTime); - - } - - public static void parseZip(String filename) throws IOException { - FileInputStream fileInputStream = new FileInputStream(filename); - parseZip(fileInputStream); - } - - public static void parseZip(InputStream is) throws IOException { - ZipInputStream zin = new ZipInputStream(is); - ZipEntry ze; - while ((ze = zin.getNextEntry()) != null) { - System.out.println(ze.getName()); - } - } -} |