Skip to content

Commit

Permalink
Use released 0.111.2-RC.0 (*RC*)
Browse files Browse the repository at this point in the history
Bump calls to allow it to work.
  • Loading branch information
arielshaqed committed Oct 4, 2023
1 parent aa75f39 commit 5bfe633
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 14 deletions.
2 changes: 1 addition & 1 deletion clients/hadoopfs/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -278,7 +278,7 @@ To export to S3:
<groupId>io.lakefs</groupId>
<!-- TODO(ariels): Publish an actual sdk-client version and use *that*! -->
<artifactId>sdk-client</artifactId>
<version>0.1.0-SNAPSHOT</version>
<version>0.111.2-RC.0</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
Expand Down
15 changes: 6 additions & 9 deletions clients/hadoopfs/src/main/java/io/lakefs/LakeFSClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ public class LakeFSClient {
private final RepositoriesApi repositoriesApi;
private final BranchesApi branchesApi;
private final ConfigApi configApi;
private final InternalApi internalApi;

public LakeFSClient(String scheme, Configuration conf) throws IOException {
String accessKey = FSConfiguration.get(conf, scheme, Constants.ACCESS_KEY_KEY_SUFFIX);
Expand Down Expand Up @@ -51,22 +52,18 @@ public LakeFSClient(String scheme, Configuration conf) throws IOException {
this.repositoriesApi = new RepositoriesApi(apiClient);
this.branchesApi = new BranchesApi(apiClient);
this.configApi = new ConfigApi(apiClient);
this.internalApi = new InternalApi(apiClient);
}

public ObjectsApi getObjectsApi() {
return objectsApi;
}
public ObjectsApi getObjectsApi() { return objectsApi; }

public StagingApi getStagingApi() {
return stagingApi;
}
public StagingApi getStagingApi() { return stagingApi; }

public RepositoriesApi getRepositoriesApi() { return repositoriesApi; }

public BranchesApi getBranchesApi() { return branchesApi; }

public ConfigApi getConfigApi() {
return configApi;
}
public ConfigApi getConfigApi() { return configApi; }

public InternalApi getInternalApi() { return internalApi; }
}
Original file line number Diff line number Diff line change
Expand Up @@ -65,9 +65,7 @@ public String createGetPhysicalAddress(S3FSTestBase o, String key) {
public StagingLocation createPutStagingLocation(S3FSTestBase o, String namespace, String repo, String branch, String path) {
String fullPath = String.format("%s/%s/%s/%s/%s-object",
o.sessionId(), namespace, repo, branch, path);
return new StagingLocation()
.token("token:simple:" + o.sessionId())
.physicalAddress(o.s3Url(fullPath));
return new StagingLocation().physicalAddress(o.s3Url(fullPath));
}
}

Expand Down Expand Up @@ -98,7 +96,6 @@ public StagingLocation createPutStagingLocation(S3FSTestBase o, String namespace
.withMethod(HttpMethod.PUT)
.withExpiration(expiration));
return new StagingLocation()
.token("token:presigned:" + o.sessionId())
.physicalAddress(o.s3Url(fullPath))
.presignedUrl(presignedUrl.toString());
}
Expand Down

0 comments on commit 5bfe633

Please sign in to comment.