aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-12-02 15:16:49 -0800
committerChris Lu <chris.lu@gmail.com>2018-12-02 15:16:49 -0800
commit4263805c78cdc906939a52d8aa165f55db36eb29 (patch)
tree4fcc211a76b56692872062150d3182638480fbbc
parenta3def2bbd98c12ec158dcdc4df2c6a578f624eb9 (diff)
downloadseaweedfs-4263805c78cdc906939a52d8aa165f55db36eb29.tar.xz
seaweedfs-4263805c78cdc906939a52d8aa165f55db36eb29.zip
resolve java jar dependencies
-rw-r--r--other/java/client/pom.xml8
-rw-r--r--other/java/client/src/main/java/seaweedfs/client/FilerGrpcClient.java4
-rw-r--r--other/java/hdfs/pom.xml33
-rw-r--r--other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystem.java12
-rw-r--r--other/java/hdfs/src/main/java/seaweed/hdfs/SeaweedFileSystemStore.java3
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,