diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-12-02 15:16:49 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-12-02 15:16:49 -0800 |
| commit | 4263805c78cdc906939a52d8aa165f55db36eb29 (patch) | |
| tree | 4fcc211a76b56692872062150d3182638480fbbc | |
| parent | a3def2bbd98c12ec158dcdc4df2c6a578f624eb9 (diff) | |
| download | seaweedfs-4263805c78cdc906939a52d8aa165f55db36eb29.tar.xz seaweedfs-4263805c78cdc906939a52d8aa165f55db36eb29.zip | |
resolve java jar dependencies
5 files changed, 48 insertions, 12 deletions
diff --git a/other/java/client/pom.xml b/other/java/client/pom.xml index 07015145e..2d5e4e31f 100644 --- a/other/java/client/pom.xml +++ b/other/java/client/pom.xml @@ -5,12 +5,13 @@ <modelVersion>4.0.0</modelVersion> <groupId>seaweedfs</groupId> - <artifactId>client</artifactId> + <artifactId>seaweedfs-client</artifactId> <version>1.0-SNAPSHOT</version> <properties> <protobuf.version>3.5.1</protobuf.version> <grpc.version>1.16.1</grpc.version> + <guava.version>26.0-jre</guava.version> </properties> <dependencies> @@ -21,6 +22,11 @@ <version>${protobuf.version}</version> </dependency> <dependency> + <groupId>com.google.guava</groupId> + <artifactId>guava</artifactId> + <version>${guava.version}</version> + </dependency> + <dependency> <groupId>io.grpc</groupId> <artifactId>grpc-netty-shaded</artifactId> <version>${grpc.version}</version> diff --git a/other/java/client/src/main/java/seaweedfs/client/FilerGrpcClient.java b/other/java/client/src/main/java/seaweedfs/client/FilerGrpcClient.java index 47712bc37..16b7c3249 100644 --- a/other/java/client/src/main/java/seaweedfs/client/FilerGrpcClient.java +++ b/other/java/client/src/main/java/seaweedfs/client/FilerGrpcClient.java @@ -16,8 +16,8 @@ public class FilerGrpcClient { private final SeaweedFilerGrpc.SeaweedFilerFutureStub futureStub; - public FilerGrpcClient(String host, int port) { - this(ManagedChannelBuilder.forAddress(host, port).usePlaintext()); + public FilerGrpcClient(String host, int grpcPort) { + this(ManagedChannelBuilder.forAddress(host, grpcPort).usePlaintext()); } public FilerGrpcClient(ManagedChannelBuilder<?> channelBuilder) { diff --git a/other/java/hdfs/pom.xml b/other/java/hdfs/pom.xml index e668e1266..963d3fc17 100644 --- a/other/java/hdfs/pom.xml +++ b/other/java/hdfs/pom.xml @@ -5,7 +5,7 @@ <modelVersion>4.0.0</modelVersion> <groupId>seaweedfs</groupId> - <artifactId>hadoop-client</artifactId> + <artifactId>seaweedfs-hadoop-client</artifactId> <version>1.0-SNAPSHOT</version> <build> <plugins> @@ -17,6 +17,35 @@ <target>7</target> </configuration> </plugin> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-shade-plugin</artifactId> + <version>3.2.1</version> + <executions> + <execution> + <phase>package</phase> + <goals> + <goal>shade</goal> + </goals> + <configuration> + <transformers> + <transformer + implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/> + </transformers> + <relocations> + <relocation> + <pattern>com.google</pattern> + <shadedPattern>shaded.com.google</shadedPattern> + </relocation> + <relocation> + <pattern>io.grpc.internal</pattern> + <shadedPattern>shaded.io.grpc.internal</shadedPattern> + </relocation> + </relocations> + </configuration> + </execution> + </executions> + </plugin> </plugins> </build> @@ -32,7 +61,7 @@ </dependency> <dependency> <groupId>seaweedfs</groupId> - <artifactId>client</artifactId> + <artifactId>seaweedfs-client</artifactId> <version>1.0-SNAPSHOT</version> </dependency> <dependency> diff --git a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java index 5599c5683..83a4938f5 100644 --- a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java +++ b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java @@ -18,8 +18,8 @@ import java.net.URI; public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem { public static final int FS_SEAWEED_DEFAULT_PORT = 8333; - public static final String FS_SEAWEED_HOST = "fs.seaweed.host"; - public static final String FS_SEAWEED_HOST_PORT = "fs.seaweed.host.port"; + public static final String FS_SEAWEED_FILER_HOST = "fs.seaweed.filer.host"; + public static final String FS_SEAWEED_FILER_PORT = "fs.seaweed.filer.port"; private URI uri; private Path workingDirectory = new Path("/"); @@ -30,7 +30,7 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem { } public String getScheme() { - return "seaweed"; + return "seaweedfs"; } @Override @@ -39,16 +39,16 @@ public class SeaweedFileSystem extends org.apache.hadoop.fs.FileSystem { // get host information from uri (overrides info in conf) String host = uri.getHost(); - host = (host == null) ? conf.get(FS_SEAWEED_HOST, null) : host; + host = (host == null) ? conf.get(FS_SEAWEED_FILER_HOST, "localhost") : host; if (host == null) { throw new IOException("Invalid host specified"); } - conf.set(FS_SEAWEED_HOST, host); + conf.set(FS_SEAWEED_FILER_HOST, host); // get port information from uri, (overrides info in conf) int port = uri.getPort(); port = (port == -1) ? FS_SEAWEED_DEFAULT_PORT : port; - conf.setInt(FS_SEAWEED_HOST_PORT, port); + conf.setInt(FS_SEAWEED_FILER_PORT, port); setConf(conf); this.uri = uri; diff --git a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java index d890762a0..0ab17a2b5 100644 --- a/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java +++ b/other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java @@ -22,7 +22,8 @@ public class SeaweedFileSystemStore { private FilerGrpcClient filerGrpcClient; public SeaweedFileSystemStore(String host, int port) { - filerGrpcClient = new FilerGrpcClient(host, port); + int grpcPort = 10000 + port; + filerGrpcClient = new FilerGrpcClient(host, grpcPort); } public boolean createDirectory(final Path path, UserGroupInformation currentUser, |
